public class FlowRunnerImpl extends java.lang.Object implements FlowRunner
Constructor and Description |
---|
FlowRunnerImpl(HubConfig hubConfig) |
Modifier and Type | Method and Description |
---|---|
void |
awaitCompletion()
Blocks until the job is complete.
|
void |
awaitCompletion(long timeout,
java.util.concurrent.TimeUnit unit)
Blocks until the job is complete.
|
FlowRunner |
onFinished(FlowFinishedListener listener)
Sets the finished listener for when the item has processed (similar to a finally)
|
FlowRunner |
onItemComplete(FlowItemCompleteListener listener)
Sets a listener on each item completing
|
FlowRunner |
onItemFailed(FlowItemFailureListener listener)
Sets the failure listener for each item in the flow
|
FlowRunner |
onStatusChanged(FlowStatusListener listener)
Sets the status change listener on the flowrunner object
|
com.marklogic.client.datamovement.JobTicket |
run()
Runs the flow and creates the job
|
FlowRunner |
withBatchSize(int batchSize)
Sets the batch size for the flow runner
|
FlowRunner |
withDestinationDatabase(java.lang.String destinationDatabase)
Sets the database where flow output data will be presisted to
|
FlowRunner |
withFlow(Flow flow)
Sets the flow to be used with the flow runner
|
FlowRunner |
withOptions(java.util.Map<java.lang.String,java.lang.Object> options)
Sets the options to be passed into the xqy or sjs flow in the $options or options variables of main.
|
FlowRunner |
withSourceClient(com.marklogic.client.DatabaseClient sourceClient)
Sets the source client on the flow runner.
|
FlowRunner |
withStopOnFailure(boolean stopOnFailure)
Sets if this will stop the job on a failure, or if it will continue on
|
FlowRunner |
withThreadCount(int threadCount)
Sets the thread count for the flowrunner
|
public FlowRunnerImpl(HubConfig hubConfig)
public FlowRunner withFlow(Flow flow)
FlowRunner
withFlow
in interface FlowRunner
flow
- the flow object to be usedpublic FlowRunner withBatchSize(int batchSize)
FlowRunner
withBatchSize
in interface FlowRunner
batchSize
- - the size of the batch in integer formpublic FlowRunner withThreadCount(int threadCount)
FlowRunner
withThreadCount
in interface FlowRunner
threadCount
- - the number of threads for the flow runner to usepublic FlowRunner withSourceClient(com.marklogic.client.DatabaseClient sourceClient)
FlowRunner
withSourceClient
in interface FlowRunner
sourceClient
- - the client that will be usedpublic FlowRunner withDestinationDatabase(java.lang.String destinationDatabase)
FlowRunner
withDestinationDatabase
in interface FlowRunner
destinationDatabase
- - the name of the databasepublic FlowRunner withStopOnFailure(boolean stopOnFailure)
FlowRunner
withStopOnFailure
in interface FlowRunner
public FlowRunner withOptions(java.util.Map<java.lang.String,java.lang.Object> options)
FlowRunner
withOptions
in interface FlowRunner
options
- - the object map of options as string/object pairpublic FlowRunner onItemComplete(FlowItemCompleteListener listener)
FlowRunner
onItemComplete
in interface FlowRunner
listener
- the listen object to setpublic FlowRunner onItemFailed(FlowItemFailureListener listener)
FlowRunner
onItemFailed
in interface FlowRunner
listener
- the listener for the failures in the flowpublic FlowRunner onStatusChanged(FlowStatusListener listener)
FlowRunner
onStatusChanged
in interface FlowRunner
listener
- - the listener for when the status changespublic FlowRunner onFinished(FlowFinishedListener listener)
FlowRunner
onFinished
in interface FlowRunner
listener
- - the listener for the flow item when it finishespublic void awaitCompletion()
FlowRunner
awaitCompletion
in interface FlowRunner
public void awaitCompletion(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
FlowRunner
awaitCompletion
in interface FlowRunner
timeout
- the maximum time to waitunit
- the time unit of the timeout argumentjava.lang.InterruptedException
- if interrupted while waitingpublic com.marklogic.client.datamovement.JobTicket run()
FlowRunner
run
in interface FlowRunner