com.marklogic.client.datamovement

Interface QueryBatcherListener

public interface QueryBatcherListener

Runs processEvent on the QueryBatcher and it is a generic listener which can be registered and run when you deal at the Batcher level. One such example is it can be registered with onJobCompletion and it can be run after the Batcher finishes its execution i.e. retrieve all the URIs matching the query and execute all the listeners associated.

See Also:

processEvent

Method Summary

Modifier and Type	Method and Description
void	processEvent(QueryBatcher batcher) The method called by QueryBatcher to run your custom code at the QueryBatcher level.

Method Detail

processEvent

void processEvent(QueryBatcher batcher)

The method called by QueryBatcher to run your custom code at the QueryBatcher level. You usually implement this as a lambda expression.

For example, see the lambda expression passed to onJobCompletion:

     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())
         .onJobCompletion(batcher -> {
            JobReport report = new JobReportImpl(batcher);
            System.out.println("Success Batch count " + report.getSuccessBatchesCount());
         });
     JobTicket ticket = dataMovementManager.startJob(qhb);
     qhb.awaitCompletion();
     dataMovementManager.stopJob(ticket);

Parameters:

batcher - the QueryBatcher associated with the listener