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

public class TransactionBatchingDocumentPipeImpl
extends DocumentPipeImpl

Alternative to the default DocumentPipe that handles Transactions demarcation aligned with the Pipe batch size

Author:

Tiry

Constructor Summary

Constructors

Constructor	Description
TransactionBatchingDocumentPipeImpl(int pageSize)

Method Summary

Modifier and Type	Method	Description
protected void	handleBatchEnd()

Methods inherited from class org.nuxeo.ecm.core.io.impl.DocumentPipeImpl

addTransformer, applyTransforms, applyTransforms, getReader, getTransformers, getWriter, readAndWriteDocs, removeTransformer, run, setReader, setWriter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionBatchingDocumentPipeImpl

public TransactionBatchingDocumentPipeImpl(int pageSize)

Method Detail

handleBatchEnd

protected void handleBatchEnd()

Overrides:

handleBatchEnd in class DocumentPipeImpl