The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
-
class
class
Sends a Java API bulk
delete request for all the documents from each
batch.
class
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
An extension of ExportListener which facilitates
writing all documents to a single Writer output stream.
class
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
Reports on progress as batches are processed by
sending an instance of the nested ProgressUpdate interface to
instances of java.util.function.Consumer.
class
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.
Get the array of QueryBatchListener instances
registered via onUrisReady.
Initializes the RetryListener for the given
QueryBatchListener.
When documents were not found and therefore not
transformed, run this listener code.
When a batch has been successfully transformed,
run this listener code.
Add a listener to run each time a batch of uris
is ready.
void
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
Remove any existing QueryBatchListener instances
registered via onUrisReady and replace them with the provided
listeners.
Copyright (c) 2010-2025 Progress
Software Corporation and/or its subsidiaries or affiliates. All
Rights Reserved.