Package org.nuxeo.ecm.core.io.impl
Class TransactionBatchingDocumentPipeImpl
java.lang.Object
org.nuxeo.ecm.core.io.impl.DocumentPipeImpl
org.nuxeo.ecm.core.io.impl.TransactionBatchingDocumentPipeImpl
- All Implemented Interfaces:
DocumentPipe
Alternative to the default
DocumentPipe
that handles Transactions demarcation aligned with the Pipe batch
size- Author:
- Tiry
-
Constructor Summary
-
Method Summary
Methods inherited from class org.nuxeo.ecm.core.io.impl.DocumentPipeImpl
addTransformer, applyTransforms, applyTransforms, getReader, getTransformers, getWriter, readAndWriteDocs, removeTransformer, run, setReader, setWriter
-
Constructor Details
-
TransactionBatchingDocumentPipeImpl
public TransactionBatchingDocumentPipeImpl(int pageSize)
-
-
Method Details
-
handleBatchEnd
protected void handleBatchEnd()- Overrides:
handleBatchEnd
in classDocumentPipeImpl
-