Package org.nuxeo.ecm.platform.csv.export.computation

Class CSVProjectionComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

org.nuxeo.ecm.platform.csv.export.computation.CSVProjectionComputation

All Implemented Interfaces:

Computation

public class CSVProjectionComputation
extends AbstractBulkComputation

Inputs:

• i1: Reads BulkBucket

Outputs

• o1: Writes Record containing csv lines

Since:

10.3

Field Summary

Fields

Modifier and Type	Field	Description
protected OutputStreamWithCSVWriter	out
static final String	PARAM_LANG
static final String	PARAM_SCHEMAS
static final String	PARAM_XPATHS
protected RenderingContext	renderingCtx

Fields inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

command, commands, delta, SELECT_DOCUMENTS_IN

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
CSVProjectionComputation()

Method Summary

Modifier and Type	Method	Description
protected void	compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)
void	endBucket(ComputationContext context, BulkStatus delta)	Can be overridden to write to downstream computation or add results to status
protected String	getData(String csv, String recordSeparator)
protected String	getHeader(String csv, String recordSeparator)
protected List<String>	getList(Serializable value)
protected String	getString(Serializable value)
void	startBucket(String bucketKey)	Can be overridden to init stuff before processing the bucket

Methods inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

getBatchTransactionTimeout, getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, loadDocumentsOneByOne, loginSystemOrUser, processBatchOfDocuments, processFailure, processRecord, updateStatus

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

init, metadata, processRetry, processTimer

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

destroy, signalStop

Field Details

PARAM_SCHEMAS

public static final String PARAM_SCHEMAS

See Also:

• Constant Field Values

PARAM_XPATHS

public static final String PARAM_XPATHS

See Also:

• Constant Field Values

PARAM_LANG

public static final String PARAM_LANG

See Also:

• Constant Field Values

out

protected OutputStreamWithCSVWriter out

renderingCtx

protected RenderingContext renderingCtx

Constructor Details

CSVProjectionComputation

public CSVProjectionComputation()

Method Details

startBucket

public void startBucket(String bucketKey)

Description copied from class: AbstractBulkComputation

Can be overridden to init stuff before processing the bucket

Overrides:

startBucket in class AbstractBulkComputation

compute

protected void compute(CoreSession session,
 List<String> ids,
 Map<String,Serializable> properties)

Specified by:

compute in class AbstractBulkComputation

endBucket

public void endBucket(ComputationContext context,
 BulkStatus delta)

Description copied from class: AbstractBulkComputation

Can be overridden to write to downstream computation or add results to status

Overrides:

endBucket in class AbstractBulkComputation

getHeader

protected String getHeader(String csv,
 String recordSeparator)

getData

protected String getData(String csv,
 String recordSeparator)

getList

protected List<String> getList(Serializable value)

getString

protected String getString(Serializable value)