Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
|
Modifier and Type | Interface | Description |
---|---|---|
interface |
QueryBatchListener |
Runs processEvent on each batch as it is ready
during a QueryBatcher job.
|
interface |
RowBatchSuccessListener<T> |
Provides a callback (typically as a lambda) to
process a batch of rows retrieved for a view.
|
interface |
WriteBatchListener |
Runs processEvent on each batch as it is ready
during a WriteBatcher job.
|
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. |
Copyright © 2022 MarkLogic Corporation