com.marklogic.hub.job.impl

Class JobMonitorImpl

java.lang.Object

com.marklogic.hub.job.impl.JobMonitorImpl

All Implemented Interfaces:

JobMonitor

public class JobMonitorImpl
extends java.lang.Object
implements JobMonitor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JobMonitorImpl.Batches

Constructor Summary

Constructors

Constructor and Description
JobMonitorImpl(com.marklogic.client.DatabaseClient client)

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.String>	getBatchResponse(java.lang.String jobId, java.lang.String batchId) Returns the response (uris or error msgs) of the batch
java.lang.String	getBatchStatus(java.lang.String jobId, java.lang.String batchId) Sets the flow to be used with the flow runner
java.util.Map<java.lang.String,java.lang.String>	getCurrentJobs() Gets the current running jobs
java.lang.String	getJobStatus(java.lang.String jobId) Sets the flow to be used with the flow runner
java.util.Map<java.lang.String,java.lang.String>	getStepBatchStatus(java.lang.String jobId, java.lang.String step) Sets the flow to be used with the flow runner

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobMonitorImpl

public JobMonitorImpl(com.marklogic.client.DatabaseClient client)

Method Detail

getCurrentJobs

public java.util.Map<java.lang.String,java.lang.String> getCurrentJobs()

Description copied from interface: JobMonitor

Gets the current running jobs

Specified by:

getCurrentJobs in interface JobMonitor

Returns:

A map of the current running job ids and their status

getJobStatus

public java.lang.String getJobStatus(java.lang.String jobId)

Description copied from interface: JobMonitor

Sets the flow to be used with the flow runner

Specified by:

getJobStatus in interface JobMonitor

Parameters:

jobId - the flow object to be used

Returns:

string denoting the status of the running job, ex: "running step 1"

getStepBatchStatus

public java.util.Map<java.lang.String,java.lang.String> getStepBatchStatus(java.lang.String jobId,
                                                                           java.lang.String step)

Description copied from interface: JobMonitor

Sets the flow to be used with the flow runner

Specified by:

getStepBatchStatus in interface JobMonitor

Parameters:

jobId - the id of the batch

step - the step of the job

Returns:

Map containing batch id and status of the batch

getBatchStatus

public java.lang.String getBatchStatus(java.lang.String jobId,
                                       java.lang.String batchId)

Description copied from interface: JobMonitor

Sets the flow to be used with the flow runner

Specified by:

getBatchStatus in interface JobMonitor

Parameters:

jobId - the id of the job

batchId - the id of the batch

Returns:

string denoting status of the batch

getBatchResponse

public java.util.List<java.lang.String> getBatchResponse(java.lang.String jobId,
                                                         java.lang.String batchId)

Description copied from interface: JobMonitor

Returns the response (uris or error msgs) of the batch

Specified by:

getBatchResponse in interface JobMonitor

Parameters:

jobId - the id of the job

batchId - the id of the batch

Returns:

the flow runner object