com.aliyun.odps.storage.write

Class AppendTableRecordWriter

java.lang.Object

com.aliyun.odps.storage.write.AppendTableRecordWriter

All Implemented Interfaces:

RecordWriter, Closeable, AutoCloseable

Direct Known Subclasses:

DeltaTableRecordWriter

public class AppendTableRecordWriter
extends Object
implements RecordWriter

Constructor Summary

Constructors

Constructor and Description
AppendTableRecordWriter(TableArrowWriter arrowWriter, long recordCountPerBatch)

Method Summary

Modifier and Type	Method and Description
long	bytesWritten()
void	close()
void	flush()
String	getLastRequestId() Returns the request ID of the last write (flush) for this stream.
Record	newRecord(boolean caseSensitive) Record can be reused, and recommend reuse it.
Blob	uploadBlob(long columnId, InputStream data)
void	write(Record r)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.aliyun.odps.data.RecordWriter

delete

Constructor Detail

AppendTableRecordWriter

public AppendTableRecordWriter(TableArrowWriter arrowWriter,
                               long recordCountPerBatch)

Method Detail

newRecord

public Record newRecord(boolean caseSensitive)

Record can be reused, and recommend reuse it.

Specified by:

newRecord in interface RecordWriter

write

public void write(Record r)

Specified by:

write in interface RecordWriter

bytesWritten

public long bytesWritten()

flush

public void flush()

uploadBlob

public Blob uploadBlob(long columnId,
                       InputStream data)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getLastRequestId

public String getLastRequestId()

Returns the request ID of the last write (flush) for this stream. For client-side logging.