Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports long-running write, read,
delete, or transform jobs.
|
com.marklogic.client.example.cookbook.datamovement |
Modifier and Type | Method | Description |
---|---|---|
WriteBatcher |
WriteBatcher.add(WriteEvent... docs) |
Add docs in the form of WriteEvents.
|
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.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.
|
Modifier and Type | Method | Description |
---|---|---|
JobTicket |
DataMovementManager.startJob(WriteBatcher batcher) |
Begins job tracking on the WriteBatcher.
|
Modifier and Type | Method | Description |
---|---|---|
void |
BulkLoadFromJdbcWithSimpleJoins.addRow(java.sql.ResultSet row,
WriteBatcher wb) |
|
void |
BulkLoadFromJdbcWithSimpleJoins.processEmployee(WriteBatcher wb,
Employee employee) |
|
void |
IncrementalLoadFromJdbc.processEmployee(WriteBatcher wb,
Employee employee) |
|
JobInformationRecorder |
JobInformationRecorder.withWriteBatcher(DataMovementManager dataMovementManager,
WriteBatcher writeBatcher) |
Sets the WriteBatcher object which should be used for writing the job information.
|
Copyright © 2013-2019 MarkLogic Corporation.