public class CSVProjectionComputation extends AbstractBulkComputation
Record containing csv lines| Modifier and Type | Field and Description |
|---|---|
protected OutputStreamWithCSVWriter |
out |
static String |
PARAM_LANG |
static String |
PARAM_SCHEMAS |
static String |
PARAM_XPATHS |
protected RenderingContext |
renderingCtx |
command, commands, delta, SELECT_DOCUMENTS_IN| Constructor and Description |
|---|
CSVProjectionComputation() |
| Modifier and Type | Method and 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
|
getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, processBatchOfDocuments, processFailure, processRecord, updateStatusinit, metadata, processRetry, processTimerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdestroy, signalStoppublic static final String PARAM_SCHEMAS
public static final String PARAM_XPATHS
public static final String PARAM_LANG
protected OutputStreamWithCSVWriter out
protected RenderingContext renderingCtx
public CSVProjectionComputation()
public void startBucket(String bucketKey)
AbstractBulkComputationstartBucket in class AbstractBulkComputationprotected void compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)
compute in class AbstractBulkComputationpublic void endBucket(ComputationContext context, BulkStatus delta)
AbstractBulkComputationendBucket in class AbstractBulkComputationprotected List<String> getList(Serializable value)
protected String getString(Serializable value)
Copyright © 2019 Nuxeo. All rights reserved.