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 |
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.