Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
|
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
|
Copyright © 2022 MarkLogic Corporation