Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
|
Modifier and Type | Method | 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
with PlanBuilder.
|
RowBatcher<T> |
RowBatcher.withBatchView(RawPlanDefinition viewPlan) |
Specifies the plan for getting rows from a view
from a serialized AST in JSON format.
|
RowBatcher<T> |
RowBatcher.withBatchView(RawQueryDSLPlan viewPlan) |
Specifies the plan for getting rows from a view
from a serialized Query DSL in JavaScript format.
|
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 | Description |
---|---|---|
JobTicket |
DataMovementManager.startJob(RowBatcher<?> batcher) |
Starts the RowBatcher job.
|
Copyright © 2022 MarkLogic Corporation