com.marklogic.hub.flow.impl

Class FlowRunnerImpl

java.lang.Object

com.marklogic.hub.flow.impl.FlowRunnerImpl

All Implemented Interfaces:

FlowRunner

public class FlowRunnerImpl
extends java.lang.Object
implements FlowRunner

Constructor Summary

Constructors

Constructor and Description
FlowRunnerImpl(HubConfig hubConfig)

Method Summary

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)
FlowRunner	onItemComplete(FlowItemCompleteListener listener)
FlowRunner	onItemFailed(FlowItemFailureListener listener)
FlowRunner	onStatusChanged(FlowStatusListener listener)
com.marklogic.client.datamovement.JobTicket	run()
FlowRunner	withBatchSize(int batchSize)
FlowRunner	withDestinationDatabase(java.lang.String destinationDatabase)
FlowRunner	withFlow(Flow flow)
FlowRunner	withOptions(java.util.Map<java.lang.String,java.lang.Object> options)
FlowRunner	withSourceClient(com.marklogic.client.DatabaseClient sourceClient)
FlowRunner	withStopOnFailure(boolean stopOnFailure)
FlowRunner	withThreadCount(int threadCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowRunnerImpl

public FlowRunnerImpl(HubConfig hubConfig)

Method Detail

withFlow

public FlowRunner withFlow(Flow flow)

Specified by:

withFlow in interface FlowRunner

withBatchSize

public FlowRunner withBatchSize(int batchSize)

Specified by:

withBatchSize in interface FlowRunner

withThreadCount

public FlowRunner withThreadCount(int threadCount)

Specified by:

withThreadCount in interface FlowRunner

withSourceClient

public FlowRunner withSourceClient(com.marklogic.client.DatabaseClient sourceClient)

Specified by:

withSourceClient in interface FlowRunner

withDestinationDatabase

public FlowRunner withDestinationDatabase(java.lang.String destinationDatabase)

Specified by:

withDestinationDatabase in interface FlowRunner

withStopOnFailure

public FlowRunner withStopOnFailure(boolean stopOnFailure)

Specified by:

withStopOnFailure in interface FlowRunner

withOptions

public FlowRunner withOptions(java.util.Map<java.lang.String,java.lang.Object> options)

Specified by:

withOptions in interface FlowRunner

onItemComplete

public FlowRunner onItemComplete(FlowItemCompleteListener listener)

Specified by:

onItemComplete in interface FlowRunner

onItemFailed

public FlowRunner onItemFailed(FlowItemFailureListener listener)

Specified by:

onItemFailed in interface FlowRunner

onStatusChanged

public FlowRunner onStatusChanged(FlowStatusListener listener)

Specified by:

onStatusChanged in interface FlowRunner

onFinished

public FlowRunner onFinished(FlowFinishedListener listener)

Specified by:

onFinished in interface FlowRunner

awaitCompletion

public void awaitCompletion()

Description copied from interface: FlowRunner

Blocks until the job is complete.

Specified by:

awaitCompletion in interface FlowRunner

awaitCompletion

public void awaitCompletion(long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException

Description copied from interface: FlowRunner

Blocks until the job is complete.

Specified by:

awaitCompletion in interface FlowRunner

Parameters:

timeout - the maximum time to wait

unit - the time unit of the timeout argument

Throws:

java.lang.InterruptedException - if interrupted while waiting

run

public com.marklogic.client.datamovement.JobTicket run()

Specified by:

run in interface FlowRunner