Package | Description |
---|---|
com.marklogic.client.datamovement |
The MarkLogic Data Movement SDK supports
long-running write, read, delete, or transform jobs.
|
Modifier and Type | Method and Description |
---|---|
QueryBatch |
ProgressListener.ProgressUpdate.getQueryBatch()
Gets the query batcher producing the
results.
|
QueryBatch |
ProgressListener.SimpleProgressUpdate.getQueryBatch() |
Modifier and Type | Method and 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 and 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 and 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 and Description |
---|
SimpleProgressUpdate(QueryBatch queryBatch,
long startTime, long totalResults,
double timeSoFarInSeconds)
Constructs a simple implementation of the
ProgressUpdate interface
|
Copyright © 2024 MarkLogic Corporation. All Rights Reserved.