alluxio.job.plan.transform.format.csv

Class CsvWriter

java.lang.Object

alluxio.job.plan.transform.format.csv.CsvWriter

All Implemented Interfaces:

TableWriter, Closeable, AutoCloseable

public final class CsvWriter
extends Object
implements TableWriter

A writer for writing CsvRow.

Constructor Summary

Constructors

Constructor and Description
CsvWriter()

Method Summary

Modifier and Type	Method and Description
void	close() Closes a writer, which means the table is complete now.
long	getBytes() Note that the bytes written should take compression and encoding into consideration.
int	getRows()
void	write(TableRow row) Writes a row.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.job.plan.transform.format.TableWriter

create

Constructor Detail

CsvWriter

public CsvWriter()

Method Detail

write

public void write(TableRow row)
           throws IOException

Description copied from interface: TableWriter

Writes a row.

Specified by:

write in interface TableWriter

Parameters:

row - a row

Throws:

IOException - when write fails

close

public void close()
           throws IOException

Description copied from interface: TableWriter

Closes a writer, which means the table is complete now.

Specified by:

close in interface TableWriter

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException - when failing to close the underlying output stream

getRows

public int getRows()

Specified by:

getRows in interface TableWriter

Returns:

the number of rows that have been written

getBytes

public long getBytes()

Description copied from interface: TableWriter

Note that the bytes written should take compression and encoding into consideration. If the writer writes to a file, the bytes written should be an estimate of the actual bytes written to the file.

Specified by:

getBytes in interface TableWriter

Returns:

the number of bytes that have been written