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 |
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.
|
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).
|
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.
|
Copyright © 2013-2020 MarkLogic Corporation.