Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
|
Modifier and Type | Interface | 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 | 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 | 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 © 2022 MarkLogic Corporation