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 | 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 | Method and Description |
---|---|
QueryBatchListener[] |
QueryBatcher.getQuerySuccessListeners()
Deprecated.
(as of 4.0.4) this should have been called getUrisReadyListeners
|
QueryBatchListener[] |
QueryBatcher.getUrisReadyListeners()
Get the array of QueryBatchListener instances registered via
onUrisReady.
|
Modifier and Type | Method and Description |
---|---|
BatchFailureListener<QueryBatch> |
HostAvailabilityListener.initializeRetryListener(QueryBatchListener queryBatchListener)
Initializes the RetryListener for the given QueryBatchListener.
|
ApplyTransformListener |
ApplyTransformListener.onSkipped(QueryBatchListener listener)
When documents were not found and therefore not transformed, run this
listener code.
|
ApplyTransformListener |
ApplyTransformListener.onSuccess(QueryBatchListener listener)
When a batch has been successfully transformed, run this listener code.
|
QueryBatcher |
QueryBatcher.onUrisReady(QueryBatchListener listener)
Add a listener to run each time a batch of uris is ready.
|
void |
QueryBatcher.retryListener(QueryBatch batch,
QueryBatchListener queryBatchListener)
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 |
QueryBatcher.setUrisReadyListeners(QueryBatchListener... listeners)
Remove any existing QueryBatchListener instances registered
via onUrisReady and replace them with the provided listeners.
|
Modifier and Type | Class and Description |
---|---|
class |
JobInformationRecorder.addQueryBatchSuccessInformationListener |
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.