Uses of Interface
com.marklogic.client.datamovement.Batcher

Packages that use Batcher

Package	Description
com.marklogic.client.datamovement	The MarkLogic Data Movement SDK supports long-running write, read, delete, or transform jobs.

Uses of Batcher in com.marklogic.client.datamovement

Subinterfaces of Batcher in com.marklogic.client.datamovement

Modifier and Type	Interface and Description
interface	QueryBatcher To facilitate long-running read, update, and delete use cases, coordinates threads to process batches of uris matching a query or coming from an Iterator.
interface	RowBatcher<T> Coordinates threads to export all of the rows from a view in batches.
interface	WriteBatcher To facilitate long-running write jobs, batches documents added by many external threads and coordinates internal threads to send the batches round-robin to all appropriate hosts in the cluster.

Methods in com.marklogic.client.datamovement that return Batcher

Modifier and Type	Method and Description
Batcher	JobTicket.getBatcher()
Batcher	Batcher.withBatchSize(int batchSize) The size of each batch (usually 50-500).
Batcher	Batcher.withForestConfig(ForestConfiguration forestConfig) Updates the ForestConfiguration used by this job to spread the writes or reads.
Batcher	Batcher.withJobId(java.lang.String jobId) Sets the unique id of the job to help with managing multiple concurrent jobs and start the job with the specified job id.
Batcher	Batcher.withJobName(java.lang.String jobName) Sets the name of the job to help with managing multiple concurrent jobs.
Batcher	Batcher.withThreadCount(int threadCount) The number of threads to be used internally by this job to perform concurrent tasks on batches (usually > 10).

Methods in com.marklogic.client.datamovement with parameters of type Batcher

Modifier and Type	Method and Description
static HostAvailabilityListener	HostAvailabilityListener.getInstance(Batcher batcher) Returns the first HostAvailabilityListener instance registered with the Batcher.
static NoResponseListener	NoResponseListener.getInstance(Batcher batcher) Returns the NoResponseListener instance registered with the Batcher.
void	DataMovementManager.stopJob(Batcher batcher) Immediately cancel all queued tasks, prevent new tasks from being added to the queue, and begin to free all resources.