Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports long-running write, read,
delete, or transform jobs.
|
Modifier and Type | Method and Description |
---|---|
<T> RowBatcher<T> |
DataMovementManager.newRowBatcher(ContentHandle<T> rowsHandle)
Create a new RowBatcher instance to export all of the rows
from a view in batches.
|
RowBatcher<T> |
RowBatcher.onFailure(RowBatchFailureListener listener)
Supplies a callback function (typically, a lambda) for
logging and specifying the disposition of errors.
|
RowBatcher<T> |
RowBatcher.onSuccess(RowBatchSuccessListener<T> listener)
Supplies a callback function (typically, a lambda) for
processing the batch of rows.
|
RowBatcher<T> |
RowBatcher.withBatchSize(int batchSize)
Specifies the number of rows in each batch retrieved from the view.
|
RowBatcher<T> |
RowBatcher.withBatchView(PlanBuilder.ModifyPlan viewPlan)
Specifies the plan for getting rows from a view.
|
RowBatcher<T> |
RowBatcher.withConsistentSnapshot()
Enables retrieval of rows that were present in the view
at the time that the first batch was retrieved, ignoring
subsequent changes to the view.
|
RowBatcher<T> |
RowBatcher.withForestConfig(ForestConfiguration forestConfig)
Specifies the forest configuration, which also identifies
the enodes for the cluster when not using a load balancer.
|
RowBatcher<T> |
RowBatcher.withJobId(java.lang.String jobId)
Specifies the identifier for the job executed by the RowBatcher.
|
RowBatcher<T> |
RowBatcher.withJobName(java.lang.String jobName)
Specifies the name for the job executed by the RowBatcher.
|
RowBatcher<T> |
RowBatcher.withThreadCount(int threadCount)
Specifies how many batches of rows to retrieve concurrently
from the view.
|
Modifier and Type | Method and Description |
---|---|
JobTicket |
DataMovementManager.startJob(RowBatcher<?> batcher)
Starts the RowBatcher job.
|
Copyright © 2013-2020 MarkLogic Corporation.