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 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
|
Modifier and Type | Field and Description |
---|---|
protected java.util.function.Function<QueryBatch,PlanBuilder.Plan> |
OpticExportListener.exportFunction |
Modifier and Type | Method and 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 and 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-2020 MarkLogic Corporation.