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 and Description |
---|---|
interface |
QueryBatchListener
Runs processEvent on each batch as it is ready during a QueryBatcher
job.
|
interface |
WriteBatchListener
Runs processEvent on each batch as it is ready during a WriteBatcher
job.
|
Modifier and Type | Class and 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 and 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-2018 MarkLogic Corporation.