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

Class TextOutputWriter

java.lang.Object

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

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

All Implemented Interfaces:

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

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

Write a text file, every record is written to a new line

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
TextOutputWriter(FileSystem.WriteMode writeMode, Path outPath)
TextOutputWriter(FileSystem.WriteMode writeMode, Path outPath, Config cfg)

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
void	setHeaders(java.lang.String[] headerNames)
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

TextOutputWriter

public TextOutputWriter(FileSystem.WriteMode writeMode,
                        Path outPath)

TextOutputWriter

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

Method Detail

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

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

setHeaders

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

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>