Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
|
Modifier and Type | Class | Description |
---|---|---|
class |
ApplyTransformListener |
Modifies documents in-place in the database by
applying a
server-side
transform . |
class |
DeleteListener |
Sends a Java API bulk
delete request for all the documents from each
batch. |
class |
ExportListener |
Reads document contents (and optionally
metadata) for each batch, then sends each document to any listeners
registered with
onDocumentReady for further processing or writing
to any target supported by Java. |
class |
ExportToWriterListener |
An extension of ExportListener which facilitates
writing all documents to a single Writer output stream.
|
class |
ExtractRowsViaTemplateListener |
This QueryBatchListener takes in one or more
uris for templates as defined by Marklogic TDE (Template Driven
Extraction) and applies them to each batch of documents.
|
class |
ProgressListener |
Reports on progress as batches are processed by
sending an instance of the nested ProgressUpdate interface to
instances of java.util.function.Consumer.
|
class |
UrisToWriterListener |
Facilitates writing uris to a file when
necessary because setting merge
timestamp and
withConsistentSnapshot is not an option, but you
need to run DeleteListener or ApplyTransformListener. |
Modifier and Type | Method | Description |
---|---|---|
QueryBatchListener[] |
QueryBatcher.getQuerySuccessListeners() |
Deprecated.
(as of 4.0.4) this should have been called getUrisReadyListeners
|
QueryBatchListener[] |
QueryBatcher.getUrisReadyListeners() |
Get the array of QueryBatchListener instances
registered via onUrisReady.
|
Modifier and Type | Method | Description |
---|---|---|
BatchFailureListener<QueryBatch> |
HostAvailabilityListener.initializeRetryListener(QueryBatchListener queryBatchListener) |
Initializes the RetryListener for the given
QueryBatchListener.
|
ApplyTransformListener |
ApplyTransformListener.onSkipped(QueryBatchListener listener) |
When documents were not found and therefore not
transformed, run this listener code.
|
ApplyTransformListener |
ApplyTransformListener.onSuccess(QueryBatchListener listener) |
When a batch has been successfully transformed,
run this listener code.
|
QueryBatcher |
QueryBatcher.onUrisReady(QueryBatchListener listener) |
Add a listener to run each time a batch of uris
is ready.
|
void |
QueryBatcher.retryListener(QueryBatch batch,
QueryBatchListener queryBatchListener) |
Retries processing the listener to the batch of
URIs, when the batch has been successfully retrieved from the
server but applying the listener on the batch failed.
|
void |
QueryBatcher.setUrisReadyListeners(QueryBatchListener... listeners) |
Remove any existing QueryBatchListener instances
registered via onUrisReady and replace them with the provided
listeners.
|
Copyright © 2022 MarkLogic Corporation