com.marklogic.client.datamovement

Interface WriteBatchListener

All Superinterfaces:

BatchListener<WriteBatch>

public interface WriteBatchListener
extends BatchListener<WriteBatch>

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

See Also:

processEvent

Method Summary

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

Method Detail

processEvent

void processEvent(WriteBatch batch)

The method called by 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 onBatchSuccess:

     WriteBatcher wb = dataMovementManager.newWriteBatcher(query)
         .withBatchSize(1000)
         .withThreadCount(20)
         .onBatchSuccess(batch -> {
             for ( WriteEvent doc : batch.getItems() ) {
                 if ( doc.getTargetUri().contains("/legal/") ) {
                     // do something
                 }
             }
         })
         .onBatchFailure(throwable -> throwable.printStackTrace());

Specified by:

processEvent in interface BatchListener<WriteBatch>

Parameters:

batch - the batch of documents written and some metadata about the current status of the job