| 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 |
|---|---|
QueryBatcher |
QueryEvent.getBatcher()
A reference to the batcher–useful for modifying the
ForestConfiguration or calling DataMovementManager.stopJob(Batcher) if needed. |
QueryBatcher |
QueryBatchException.getBatcher()
The QueryBatcher assocated with this event–useful for modifying the
ForestConfiguration or calling DataMovementManager.stopJob(Batcher) if needed. |
QueryBatcher |
DataMovementManager.newQueryBatcher(Iterator<String> iterator)
Create a new QueryBatcher instance configured to retrieve uris from this Iterator.
|
QueryBatcher |
DataMovementManager.newQueryBatcher(RawCombinedQueryDefinition query)
Create a new QueryBatcher instance configured to retrieve uris that match this query.
|
QueryBatcher |
DataMovementManager.newQueryBatcher(RawStructuredQueryDefinition query)
Create a new QueryBatcher instance configured to retrieve uris that match this query.
|
QueryBatcher |
DataMovementManager.newQueryBatcher(StringQueryDefinition query)
Create a new QueryBatcher instance configured to retrieve uris that match this query.
|
QueryBatcher |
DataMovementManager.newQueryBatcher(StructuredQueryDefinition query)
Create a new QueryBatcher instance configured to retrieve uris that match this query.
|
QueryBatcher |
QueryBatcher.onQueryFailure(QueryFailureListener listener)
Add a listener to run each time there is an exception retrieving a batch of uris.
|
QueryBatcher |
QueryBatcher.onUrisReady(QueryBatchListener listener)
Add a listener to run each time a batch of uris is ready.
|
QueryBatcher |
QueryBatcher.withBatchSize(int batchSize)
Sets the number of uris to retrieve per batch.
|
QueryBatcher |
QueryBatcher.withConsistentSnapshot()
Specifies that matching uris should be retrieved as they were when this QueryBatcher job started.
|
QueryBatcher |
QueryBatcher.withForestConfig(ForestConfiguration forestConfig)
If the server forest configuration changes mid-job, it can be re-fetched with
DataMovementManager.readForestConfig() then set via withForestConfig. |
QueryBatcher |
QueryBatcher.withJobName(String jobName)
Sets the job name.
|
QueryBatcher |
QueryBatcher.withThreadCount(int threadCount)
Sets the number of threads added to the internal thread pool for this instance to use for retrieving or processing batches of uris.
|
| Modifier and Type | Method and Description |
|---|---|
JobTicket |
DataMovementManager.startJob(QueryBatcher batcher)
Starts the QueryBatcher job.
|
Copyright © 2013-2017 MarkLogic Corporation.