| 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 |
|---|---|
WriteBatcher |
WriteBatcher.add(String uri,
AbstractWriteHandle contentHandle)
Add a document to be batched then written to the server when a batch is full or
flushAsync() or flushAndWait() is called. |
WriteBatcher |
WriteBatcher.add(String uri,
DocumentMetadataWriteHandle metadataHandle,
AbstractWriteHandle contentHandle)
Add a document to be batched then written to the server when a batch is full or
flushAsync() or flushAndWait() is called. |
WriteBatcher |
WriteBatcher.add(WriteEvent... docs)
Add docs in the form of WriteEvents.
|
WriteBatcher |
WriteBatcher.addAs(String uri,
DocumentMetadataWriteHandle metadataHandle,
Object content)
Add a document to be batched then written to the server when a batch is full or
flushAsync() or flushAndWait() is called. |
WriteBatcher |
WriteBatcher.addAs(String uri,
Object content)
Add a document to be batched then written to the server when a batch is full or
flushAsync() or flushAndWait() is called. |
WriteBatcher |
WriteBatch.getBatcher() |
WriteBatcher |
DataMovementManager.newWriteBatcher()
Create a new WriteBatcher instance.
|
WriteBatcher |
WriteBatcher.onBatchFailure(WriteFailureListener listener)
Add a listener to run each time there is an exception writing a batch.
|
WriteBatcher |
WriteBatcher.onBatchSuccess(WriteBatchListener listener)
Add a listener to run each time a batch is successfully written.
|
WriteBatcher |
WriteBatcher.withBatchSize(int batchSize)
Sets the number of documents to send per batch.
|
WriteBatcher |
WriteBatcher.withForestConfig(ForestConfiguration forestConfig)
If the server forest configuration changes mid-job, it can be re-fetched with
DataMovementManager.readForestConfig() then set via withForestConfig. |
WriteBatcher |
WriteBatcher.withJobName(String jobName)
Sets the job name.
|
WriteBatcher |
WriteBatcher.withTemporalCollection(String collection)
The temporal collection to use for a temporal document insert
|
WriteBatcher |
WriteBatcher.withThreadCount(int threadCount)
Sets the number of threads added to the internal thread pool for this instance to use for writing or reporting on batches of uris.
|
WriteBatcher |
WriteBatcher.withTransform(ServerTransform transform)
The ServerTransform to modify each document from each batch before it is written to the database.
|
| Modifier and Type | Method and Description |
|---|---|
JobTicket |
DataMovementManager.startJob(WriteBatcher batcher)
Begins job tracking on the WriteBatcher.
|
Copyright © 2013-2017 MarkLogic Corporation.