com.northconcepts.datapipeline.foundations.pipeline.output

Class CsvPipelineOutput

java.lang.Object

com.northconcepts.datapipeline.foundations.core.Bean

com.northconcepts.datapipeline.foundations.core.FoundationObject

com.northconcepts.datapipeline.foundations.pipeline.PipelineObject

com.northconcepts.datapipeline.foundations.pipeline.PipelineOutput

com.northconcepts.datapipeline.foundations.pipeline.output.FileSinkPipelineOutput

com.northconcepts.datapipeline.foundations.pipeline.output.CsvPipelineOutput

All Implemented Interfaces:

DataExceptionContributor, JsonSerializable, RecordSerializable, XmlSerializable, DataWriterFactory, JavaCodeGenerator, Serializable

public class CsvPipelineOutput
extends FileSinkPipelineOutput

See Also:

Serialized Form

Field Summary

Fields inherited from class com.northconcepts.datapipeline.foundations.core.FoundationObject

internalId, internalName, log, TIMESTAMP_FORMAT

Fields inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

SERIALIZED_CLASS_NAME, TYPE

Fields inherited from interface com.northconcepts.datapipeline.core.XmlSerializable

XML_SERIALIZED_CLASS_NAME

Constructor Summary

Constructors

Constructor and Description
CsvPipelineOutput()

Method Summary

Modifier and Type	Method and Description
DataWriter	createDataWriter()
CsvPipelineOutput	fromRecord(Record source) Loads this instance's state from a record and returns this (for fluid API call chaining).
CsvPipelineOutput	fromXmlElement(Element pipelineOutputElement)
void	generateJavaCode(JavaCodeBuilder code)
void	generateSaveCode(JavaCodeBuilder javaCodeBuilder)
String	getCharset()
CSVWriter.ValuePolicy	getEmptyStringValuePolicy()
String	getEndingQuote()
String	getFieldSeparator()
FileSink	getFileSink()
String	getName()
String	getNewLine()
String	getNewLineEscaped()
CSVWriter.ValuePolicy	getNullValuePolicy()
String	getStartingQuote()
boolean	isAutoCloseWriter()
boolean	isFieldNamesInFirstRow()
boolean	isFlushOnWrite()
boolean	isForceQuote()
CsvPipelineOutput	setAutoCloseWriter(boolean autoCloseWriter)
CsvPipelineOutput	setCharset(String charset)
CsvPipelineOutput	setEmptyStringValuePolicy(CSVWriter.ValuePolicy emptyStringValuePolicy)
CsvPipelineOutput	setEndingQuote(String endingQuote)
CsvPipelineOutput	setFieldNamesInFirstRow(boolean fieldNamesInFirstRow)
CsvPipelineOutput	setFieldSeparator(String fieldSeparator)
CsvPipelineOutput	setFileSink(FileSink fileSink)
CsvPipelineOutput	setFlushOnWrite(boolean flushOnWrite)
CsvPipelineOutput	setForceQuote(boolean forceQuote)
CsvPipelineOutput	setNewLine(String newLine)
CsvPipelineOutput	setNewLineEscaped(String newLine)
CsvPipelineOutput	setNullValuePolicy(CSVWriter.ValuePolicy nullValuePolicy)
CsvPipelineOutput	setStartingQuote(String startingQuote)
Record	toRecord()
Element	toXmlElement(Document document)

Methods inherited from class com.northconcepts.datapipeline.foundations.pipeline.PipelineOutput

getNestedPipelineOutput, getRootPipelineOutput

Methods inherited from class com.northconcepts.datapipeline.foundations.core.FoundationObject

addExceptionProperties, assertValid, assertValid, clone, exception, exception, exception, getInternalId, getInternalName, resetInternalId

Methods inherited from class com.northconcepts.datapipeline.foundations.core.Bean

toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.northconcepts.datapipeline.core.RecordSerializable

fromArrayValue, fromArrayValue, fromArrayValue, fromJson, fromJson, newInstanceFromRecord, newInstanceFromRecord, toArrayValue, toJson, toJson, toJson, toRecord

Methods inherited from interface com.northconcepts.datapipeline.core.JsonSerializable

newInstanceFromJson

Methods inherited from interface com.northconcepts.datapipeline.core.XmlSerializable

forEachGrandChildElement, fromXml, fromXml, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getAttribute, getChildElement, getChildElements, newInstanceFromXml, newInstanceFromXml, setAttribute, toXml, toXml, toXml, toXml, toXml, writeXml, writeXml

Methods inherited from interface com.northconcepts.datapipeline.core.DataExceptionContributor

addExceptionProperties, contributeExceptionProperties, contributeExceptionProperties

Constructor Detail

CsvPipelineOutput

public CsvPipelineOutput()

Method Detail

getName

public String getName()

Overrides:

getName in class FileSinkPipelineOutput

toRecord

public Record toRecord()

Specified by:

toRecord in interface RecordSerializable

Overrides:

toRecord in class Bean

fromRecord

public CsvPipelineOutput fromRecord(Record source)

Description copied from interface: RecordSerializable

Loads this instance's state from a record and returns this (for fluid API call chaining). For fluid API call chaining, the overridden method should change the declared return type to its class.

Specified by:

fromRecord in interface RecordSerializable

Overrides:

fromRecord in class PipelineOutput

Returns:

this instance.

getFieldSeparator

public String getFieldSeparator()

setFieldSeparator

public CsvPipelineOutput setFieldSeparator(String fieldSeparator)

getStartingQuote

public String getStartingQuote()

setStartingQuote

public CsvPipelineOutput setStartingQuote(String startingQuote)

getEndingQuote

public String getEndingQuote()

setEndingQuote

public CsvPipelineOutput setEndingQuote(String endingQuote)

getNewLine

public String getNewLine()

setNewLine

public CsvPipelineOutput setNewLine(String newLine)

getNewLineEscaped

public String getNewLineEscaped()

setNewLineEscaped

public CsvPipelineOutput setNewLineEscaped(String newLine)

getNullValuePolicy

public CSVWriter.ValuePolicy getNullValuePolicy()

setNullValuePolicy

public CsvPipelineOutput setNullValuePolicy(CSVWriter.ValuePolicy nullValuePolicy)

getEmptyStringValuePolicy

public CSVWriter.ValuePolicy getEmptyStringValuePolicy()

setEmptyStringValuePolicy

public CsvPipelineOutput setEmptyStringValuePolicy(CSVWriter.ValuePolicy emptyStringValuePolicy)

isForceQuote

public boolean isForceQuote()

setForceQuote

public CsvPipelineOutput setForceQuote(boolean forceQuote)

isAutoCloseWriter

public boolean isAutoCloseWriter()

setAutoCloseWriter

public CsvPipelineOutput setAutoCloseWriter(boolean autoCloseWriter)

isFlushOnWrite

public boolean isFlushOnWrite()

setFlushOnWrite

public CsvPipelineOutput setFlushOnWrite(boolean flushOnWrite)

isFieldNamesInFirstRow

public boolean isFieldNamesInFirstRow()

setFieldNamesInFirstRow

public CsvPipelineOutput setFieldNamesInFirstRow(boolean fieldNamesInFirstRow)

createDataWriter

public DataWriter createDataWriter()

getFileSink

public FileSink getFileSink()

Specified by:

getFileSink in class FileSinkPipelineOutput

setFileSink

public CsvPipelineOutput setFileSink(FileSink fileSink)

Specified by:

setFileSink in class FileSinkPipelineOutput

generateSaveCode

public void generateSaveCode(JavaCodeBuilder javaCodeBuilder)

Overrides:

generateSaveCode in class FileSinkPipelineOutput

generateJavaCode

public void generateJavaCode(JavaCodeBuilder code)

getCharset

public String getCharset()

setCharset

public CsvPipelineOutput setCharset(String charset)

toXmlElement

public Element toXmlElement(Document document)

Specified by:

toXmlElement in interface XmlSerializable

Overrides:

toXmlElement in class PipelineOutput

fromXmlElement

public CsvPipelineOutput fromXmlElement(Element pipelineOutputElement)