edu.iu.dsc.tws.data.api.out

Class CSVOutputWriter

java.lang.Object

edu.iu.dsc.tws.data.api.out.FileOutputWriter<java.lang.String>

edu.iu.dsc.tws.data.api.out.CSVOutputWriter

All Implemented Interfaces:

OutputWriter<java.lang.String>, java.io.Serializable

public class CSVOutputWriter
extends FileOutputWriter<java.lang.String>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	fieldDelimiter
protected static java.lang.String	lineDelimiter
protected static java.lang.String	tabDelimiter

Fields inherited from class edu.iu.dsc.tws.data.api.out.FileOutputWriter

fs, openStreams, outPath, pw, writeMode

Constructor Summary

Constructors

Constructor and Description
CSVOutputWriter(FileSystem.WriteMode writeMode, Path outPath)
CSVOutputWriter(FileSystem.WriteMode writeMode, Path outPath, Config cfg)
CSVOutputWriter(FileSystem.WriteMode writeMode, Path outPath, java.lang.String linedelimiter, java.lang.String fielddelimiter, java.lang.String tabdelimiter, Config cfg, java.lang.String charsetName)

Method Summary

Modifier and Type	Method and Description
void	close() Close the writer, flush everything
void	createOutput()
void	createOutput(int partition, FSDataOutputStream out) Create a suitable output
boolean	isAllowedNullValues()
boolean	isQuoteStrings()
void	setAllowedNullValues(boolean allowedNullValues)
void	setCharsetName(java.lang.String charsetName)
void	setHeaders(java.lang.String[] headerNames)
void	setQuoteStrings(boolean quoteStrings)
void	writeRecord(int partition, java.lang.String data) Write the record to output
void	writeRecord(java.lang.String data)

Methods inherited from class edu.iu.dsc.tws.data.api.out.FileOutputWriter

configure, generateRandom, getWriteMode, setWriteMode, write, write

Methods inherited from class java.lang.Object

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

Field Detail

lineDelimiter

protected static java.lang.String lineDelimiter

fieldDelimiter

protected static java.lang.String fieldDelimiter

tabDelimiter

protected static java.lang.String tabDelimiter

Constructor Detail

CSVOutputWriter

public CSVOutputWriter(FileSystem.WriteMode writeMode,
                       Path outPath)

CSVOutputWriter

public CSVOutputWriter(FileSystem.WriteMode writeMode,
                       Path outPath,
                       Config cfg)

CSVOutputWriter

public CSVOutputWriter(FileSystem.WriteMode writeMode,
                       Path outPath,
                       java.lang.String linedelimiter,
                       java.lang.String fielddelimiter,
                       java.lang.String tabdelimiter,
                       Config cfg,
                       java.lang.String charsetName)

Method Detail

isAllowedNullValues

public boolean isAllowedNullValues()

setAllowedNullValues

public void setAllowedNullValues(boolean allowedNullValues)

isQuoteStrings

public boolean isQuoteStrings()

setQuoteStrings

public void setQuoteStrings(boolean quoteStrings)

setCharsetName

public void setCharsetName(java.lang.String charsetName)

createOutput

public void createOutput(int partition,
                         FSDataOutputStream out)

Description copied from class: FileOutputWriter

Create a suitable output

Specified by:

createOutput in class FileOutputWriter<java.lang.String>

Parameters:

partition - partition id

out - the out stream

setHeaders

public void setHeaders(java.lang.String[] headerNames)

writeRecord

public void writeRecord(int partition,
                        java.lang.String data)

Description copied from class: FileOutputWriter

Write the record to output

Specified by:

writeRecord in class FileOutputWriter<java.lang.String>

Parameters:

partition - partition id

data - data

createOutput

public void createOutput()

writeRecord

public void writeRecord(java.lang.String data)

Specified by:

writeRecord in class FileOutputWriter<java.lang.String>

close

public void close()

Description copied from interface: OutputWriter

Close the writer, flush everything

Specified by:

close in interface OutputWriter<java.lang.String>

Overrides:

close in class FileOutputWriter<java.lang.String>