Uses of Interface
com.marklogic.client.datamovement.WriteBatcher

Packages that use WriteBatcher

Package	Description
com.marklogic.client.datamovement	The MarkLogic Data Movement SDK supports long-running write, read, delete, or transform jobs.

Uses of WriteBatcher in com.marklogic.client.datamovement

Methods in com.marklogic.client.datamovement that return WriteBatcher

Modifier and Type	Method and Description
WriteBatcher	WriteBatcher.add(DocumentWriteOperation writeOperation) Add a document, by passing in a DocumentWriteOperation, to be batched and then written to the server when a batch is full or flushAsync() or flushAndWait() is called.
WriteBatcher	WriteBatcher.add(java.lang.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(java.lang.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(java.lang.String uri, DocumentMetadataWriteHandle metadataHandle, java.lang.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(java.lang.String uri, java.lang.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.withDefaultMetadata(DocumentMetadataHandle handle) Sets the DocumentMetadataHandle for write operations.
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.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.
WriteBatcher	WriteBatcher.withJobName(java.lang.String jobName) Sets the job name.
WriteBatcher	WriteBatcher.withTemporalCollection(java.lang.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.

Methods in com.marklogic.client.datamovement with parameters of type WriteBatcher

Modifier and Type	Method and Description
JobTicket	DataMovementManager.startJob(WriteBatcher batcher) Begins job tracking on the WriteBatcher.