com.aliyun.odps.mapred.local

Class CSVRecordWriter

java.lang.Object

com.aliyun.odps.mapred.local.CSVRecordWriter

All Implemented Interfaces:

RecordWriter, Closeable, AutoCloseable

public class CSVRecordWriter
extends Object
implements RecordWriter

Constructor Summary

Constructors

Constructor and Description
CSVRecordWriter(File file, com.aliyun.odps.counter.Counter recordCounter, com.aliyun.odps.counter.Counter byteCounter, char outputColumnSeperator)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getLen()
void	write(Record record)
void	write(RecordPack pack)

Methods inherited from class java.lang.Object

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

Constructor Detail

CSVRecordWriter

public CSVRecordWriter(File file,
                       com.aliyun.odps.counter.Counter recordCounter,
                       com.aliyun.odps.counter.Counter byteCounter,
                       char outputColumnSeperator)
                throws IOException

Throws:

IOException

Method Detail

write

public void write(Record record)
           throws IOException

Specified by:

write in interface RecordWriter

Throws:

IOException

write

public void write(RecordPack pack)
           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getLen

public long getLen()
            throws IOException

Throws:

IOException