| Package | Description |
|---|---|
| com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports long-running write, read, delete, or transform jobs.
|
| 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 |
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.
|
| Modifier and Type | Method and Description |
|---|---|
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.withJobName(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).
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
Copyright © 2013-2017 MarkLogic Corporation.