com.marklogic.client.datamovement

Interface BatchListener<T extends BatchEvent>

All Known Subinterfaces:

QueryBatchListener, RowBatchSuccessListener<T>, WriteBatchListener

All Known Implementing Classes:

ApplyTransformListener, DeleteListener, ExportListener, ExportToWriterListener, ExtractRowsViaTemplateListener, ProgressListener, UrisToWriterListener

public interface BatchListener<T extends BatchEvent>

Runs processEvent on each batch as it is ready during a QueryBatcher or WriteBatcher job.

See Also:

processEvent

Method Summary

Modifier and Type	Method and Description
void	processEvent(T batch) The method called by QueryBatcher or WriteBatcher to run your custom code on this batch.

Method Detail

processEvent

void processEvent(T batch)

The method called by QueryBatcher or WriteBatcher to run your custom code on this batch. You usually implement this as a lambda expression.

For example, see the lambda expression passed to onUrisReady:

     QueryBatcher qhb = dataMovementManager.newQueryBatcher(query)
         .withBatchSize(1000)
         .withThreadCount(20)
         .onUrisReady(batch -> {
             for ( String uri : batch.getItems() ) {
                 if ( uri.endsWith(".txt") ) {
                     batch.getClient().newDocumentManager().delete(uri);
                 }
             }
         })
         .onQueryFailure(queryBatchException -> queryBatchException.printStackTrace());
     JobTicket ticket = dataMovementManager.startJob(qhb);
     qhb.awaitCompletion();
     dataMovementManager.stopJob(ticket);

Parameters:

batch - the batch of uris and some metadata about the current status of the job