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 | Method | Description |
---|---|---|
QueryBatch |
ProgressListener.ProgressUpdate.getQueryBatch() |
Gets the query batcher producing the results.
|
QueryBatch |
ProgressListener.SimpleProgressUpdate.getQueryBatch() |
Modifier and Type | Method | Description |
---|---|---|
protected java.util.List<BatchFailureListener<QueryBatch>> |
ExportListener.getBatchFailureListeners() |
|
BatchFailureListener<QueryBatch> |
HostAvailabilityListener.initializeRetryListener(QueryBatchListener queryBatchListener) |
Initializes the RetryListener for the given QueryBatchListener.
|
Modifier and Type | Method | Description |
---|---|---|
protected DocumentPage |
ExportListener.getDocs(QueryBatch batch) |
|
protected ProgressListener.ProgressUpdate |
ProgressListener.newProgressUpdate(QueryBatch batch,
long startTime,
long totalForThisUpdate,
double timeSoFar) |
A subclass can override this to provide a different implementation of ProgressUpdate.
|
void |
ApplyTransformListener.processEvent(QueryBatch batch) |
The standard BatchListener action called by QueryBatcher.
|
void |
DeleteListener.processEvent(QueryBatch batch) |
The standard BatchListener action called by QueryBatcher.
|
void |
ExportListener.processEvent(QueryBatch batch) |
This is the method QueryBatcher calls for ExportListener to do its
thing.
|
void |
ExportToWriterListener.processEvent(QueryBatch batch) |
|
void |
ExtractRowsViaTemplateListener.processEvent(QueryBatch batch) |
This is the method QueryBatcher calls for ExtractRowsViaTemplateListener to do
its thing.
|
void |
ProgressListener.processEvent(QueryBatch batch) |
Batches arrive in random order, so a ProgressUpdate is created and sent to each Consumer only if the
value of "getJobResultsSoFar" on the QueryBatch exceeds the number of results seen so far.
|
void |
QueryBatchListener.processEvent(QueryBatch batch) |
The method called by QueryBatcher or WriteBatcher to run your
custom code on this batch.
|
void |
UrisToWriterListener.processEvent(QueryBatch batch) |
|
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.
|
Modifier and Type | Method | Description |
---|---|---|
ApplyTransformListener |
ApplyTransformListener.onFailure(BatchFailureListener<QueryBatch> listener) |
When a batch fails or a callback throws an Exception, run this listener
code.
|
DeleteListener |
DeleteListener.onFailure(BatchFailureListener<QueryBatch> listener) |
When a batch fails or a callback throws an Exception, run this listener
code.
|
ExportListener |
ExportListener.onFailure(BatchFailureListener<QueryBatch> listener) |
When a batch fails or a callback throws an Exception, run this listener
code.
|
ExtractRowsViaTemplateListener |
ExtractRowsViaTemplateListener.onFailure(BatchFailureListener<QueryBatch> listener) |
When a batch fails or a callback throws an Exception, run this listener
code.
|
UrisToWriterListener |
UrisToWriterListener.onFailure(BatchFailureListener<QueryBatch> listener) |
When a batch fails or a callback throws an Exception, run this listener
code.
|
Constructor | Description |
---|---|
SimpleProgressUpdate(QueryBatch queryBatch,
long startTime,
long totalResults,
double timeSoFarInSeconds) |
Constructs a simple implementation of the ProgressUpdate interface
|
Modifier and Type | Field | Description |
---|---|---|
protected java.util.function.Function<QueryBatch,PlanBuilder.Plan> |
OpticExportListener.exportFunction |
Modifier and Type | Method | Description |
---|---|---|
void |
JobInformationRecorder.addQueryBatchSuccessInformationListener.processEvent(QueryBatch batch) |
|
void |
OpticExportListener.processEvent(QueryBatch batch) |
This is the method QueryBatcher calls for OpticExportListener to do its
thing.
|
void |
OpticExportToWriterListener.processEvent(QueryBatch batch) |
Constructor | Description |
---|---|
OpticExportListener(java.util.function.Function<QueryBatch,PlanBuilder.Plan> function,
RowManager rowManager) |
|
OpticExportToWriterListener(java.util.function.Function<QueryBatch,PlanBuilder.Plan> function,
RowManager rowManager,
java.io.Writer writer) |
Copyright © 2013-2019 MarkLogic Corporation.