Package org.nuxeo.ecm.core.io.impl

Class DocumentPipeImpl

java.lang.Object

org.nuxeo.ecm.core.io.impl.DocumentPipeImpl

All Implemented Interfaces:

DocumentPipe

Direct Known Subclasses:

TransactionBatchingDocumentPipeImpl

public class DocumentPipeImpl
extends Object
implements DocumentPipe

Author:

Bogdan Stefanescu

Constructor Summary

Constructors

Constructor	Description
DocumentPipeImpl()
DocumentPipeImpl(int pageSize)

Method Summary

Modifier and Type	Method	Description
void	addTransformer(DocumentTransformer transformer)
void	applyTransforms(ExportedDocument doc)
void	applyTransforms(ExportedDocument[] docs)
DocumentReader	getReader()
List<DocumentTransformer>	getTransformers()
DocumentWriter	getWriter()
protected void	handleBatchEnd()
protected void	readAndWriteDocs(List<DocumentTranslationMap> maps)
void	removeTransformer(DocumentTransformer transformer)
DocumentTranslationMap	run()
void	setReader(DocumentReader reader)
void	setWriter(DocumentWriter writer)

Methods inherited from class java.lang.Object

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

Constructor Details

DocumentPipeImpl

public DocumentPipeImpl(int pageSize)

DocumentPipeImpl

public DocumentPipeImpl()

Method Details

addTransformer

public void addTransformer(DocumentTransformer transformer)

Specified by:

addTransformer in interface DocumentPipe

getReader

public DocumentReader getReader()

Specified by:

getReader in interface DocumentPipe

getTransformers

public List<DocumentTransformer> getTransformers()

Specified by:

getTransformers in interface DocumentPipe

getWriter

public DocumentWriter getWriter()

Specified by:

getWriter in interface DocumentPipe

removeTransformer

public void removeTransformer(DocumentTransformer transformer)

Specified by:

removeTransformer in interface DocumentPipe

setReader

public void setReader(DocumentReader reader)

Specified by:

setReader in interface DocumentPipe

setWriter

public void setWriter(DocumentWriter writer)

Specified by:

setWriter in interface DocumentPipe

run

public DocumentTranslationMap run()
                           throws IOException

Specified by:

run in interface DocumentPipe

Throws:

IOException

handleBatchEnd

protected void handleBatchEnd()

readAndWriteDocs

protected void readAndWriteDocs(List<DocumentTranslationMap> maps)
                         throws IOException

Throws:

IOException

applyTransforms

public void applyTransforms(ExportedDocument doc)
                     throws IOException

Throws:

IOException

applyTransforms

public void applyTransforms(ExportedDocument[] docs)
                     throws IOException

Throws:

IOException