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 | 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. |
Modifier and Type | Class | Description |
---|---|---|
class |
JobInformationRecorder.addQueryBatchSuccessInformationListener |
|
class |
JobInformationRecorder.addWriteBatchSuccessInformationListener |
|
class |
OpticExportListener |
Takes in a Function which takes QueryBatch as
argument and converts it into a Plan and then iterates the row set
returned by the constructed Plan and sends each RowRecord to any
listeners registered with
onRowRecordReady for further processing or writing
to any target supported by Java For example:
Function<QueryBatch, PlanBuilder.Plan> fn = batch -> {
PlanBuilder.Plan plan = convertToOpticPlan(batch); return plan; }
where "convertToOpticPlan" is your custom code which converts the
QueryBatch into Optic plan from which records can be
retrieved. |
class |
OpticExportToWriterListener |
An extension of OpticExportListener which
facilitates writing all row records from the constructed Plan to a
single Writer output stream.
|
Copyright © 2013-2019 MarkLogic Corporation.