LegacyFlowRunner (marklogic-data-hub 5.2.2 API)

All Known Implementing Classes:

LegacyFlowRunnerImpl
```
public interface LegacyFlowRunner
```
Executes a flow with options

Method Summary

All Methods Instance Methods Abstract Methods
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.
`LegacyFlowRunner`	`onFinished(LegacyFlowFinishedListener listener)` Sets the finished listener for when the item has processed (similar to a finally)
`LegacyFlowRunner`	`onItemComplete(LegacyFlowItemCompleteListener listener)` Sets a listener on each item completing
`LegacyFlowRunner`	`onItemFailed(LegacyFlowItemFailureListener listener)` Sets the failure listener for each item in the flow
`LegacyFlowRunner`	`onStatusChanged(LegacyFlowStatusListener listener)` Sets the status change listener on the flowrunner object
`com.marklogic.client.datamovement.JobTicket`	`run()` Runs the flow and creates the job
`LegacyFlowRunner`	`withBatchSize(int batchSize)` Sets the batch size for the flow runner
`LegacyFlowRunner`	`withDestinationDatabase(java.lang.String destinationDatabase)` Sets the database where flow output data will be presisted to
`LegacyFlowRunner`	`withFlow(LegacyFlow flow)` Sets the flow to be used with the flow runner
`LegacyFlowRunner`	`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.
`LegacyFlowRunner`	`withSourceClient(com.marklogic.client.DatabaseClient sourceClient)` Sets the source client on the flow runner.
`LegacyFlowRunner`	`withStopOnFailure(boolean stopOnFailure)` Sets if this will stop the job on a failure, or if it will continue on
`LegacyFlowRunner`	`withThreadCount(int threadCount)` Sets the thread count for the flowrunner

- Method Detail
  - withFlow
```
LegacyFlowRunner withFlow(LegacyFlow flow)
```
    Sets the flow to be used with the flow runner
    
    Parameters:
    
    flow - the flow object to be used
    
    Returns:
    
    the flow runner object
  - withBatchSize
```
LegacyFlowRunner withBatchSize(int batchSize)
```
    Sets the batch size for the flow runner
    
    Parameters:
    
    batchSize - - the size of the batch in integer form
    
    Returns:
    
    the flow runner object
  - withThreadCount
```
LegacyFlowRunner withThreadCount(int threadCount)
```
    Sets the thread count for the flowrunner
    
    Parameters:
    
    threadCount - - the number of threads for the flow runner to use
    
    Returns:
    
    the flow runner object
  - withSourceClient
```
LegacyFlowRunner withSourceClient(com.marklogic.client.DatabaseClient sourceClient)
```
    Sets the source client on the flow runner. The source client determines which database to run against for building the envelope.
    
    Parameters:
    
    sourceClient - - the client that will be used
    
    Returns:
    
    the flow runner object
  - withDestinationDatabase
```
LegacyFlowRunner withDestinationDatabase(java.lang.String destinationDatabase)
```
    Sets the database where flow output data will be presisted to
    
    Parameters:
    
    destinationDatabase - - the name of the database
    
    Returns:
    
    the flow runner object
  - withOptions
```
LegacyFlowRunner 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.
    
    Parameters:
    
    options - - the object map of options as string/object pair
    
    Returns:
    
    the flow runner object
  - withStopOnFailure
```
LegacyFlowRunner withStopOnFailure(boolean stopOnFailure)
```
    Sets if this will stop the job on a failure, or if it will continue on
    
    Parameters:
    
    stopOnFailure - - true to stop the job if a failure happens
    
    Returns:
    
    the flow runner object
  - onItemComplete
```
LegacyFlowRunner onItemComplete(LegacyFlowItemCompleteListener listener)
```
    Sets a listener on each item completing
    
    Parameters:
    
    listener - the listen object to set
    
    Returns:
    
    the flow runner object
  - onItemFailed
```
LegacyFlowRunner onItemFailed(LegacyFlowItemFailureListener listener)
```
    Sets the failure listener for each item in the flow
    
    Parameters:
    
    listener - the listener for the failures in the flow
    
    Returns:
    
    the flow runner object
  - onStatusChanged
```
LegacyFlowRunner onStatusChanged(LegacyFlowStatusListener listener)
```
    Sets the status change listener on the flowrunner object
    
    Parameters:
    
    listener - - the listener for when the status changes
    
    Returns:
    
    the flow runner object
  - onFinished
```
LegacyFlowRunner onFinished(LegacyFlowFinishedListener listener)
```
    Sets the finished listener for when the item has processed (similar to a finally)
    
    Parameters:
    
    listener - - the listener for the flow item when it finishes
    
    Returns:
    
    the flow runner object
  - awaitCompletion
```
void awaitCompletion()
```
    Blocks until the job is complete.
  - awaitCompletion
```
void awaitCompletion(long timeout,
                     java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException
```
    Blocks until the job is complete.
    
    Parameters:
    
    timeout - the maximum time to wait
    
    unit - the time unit of the timeout argument
    
    Throws:
    
    java.lang.InterruptedException - if interrupted while waiting
  - run
```
com.marklogic.client.datamovement.JobTicket run()
```
    Runs the flow and creates the job
    
    Returns:
    
    jobticket object for the flow that is run

Interface LegacyFlowRunner

Method Summary

Method Detail

withFlow

withBatchSize

withThreadCount

withSourceClient

withDestinationDatabase

withOptions

withStopOnFailure

onItemComplete

onItemFailed

onStatusChanged

onFinished

awaitCompletion

awaitCompletion

run