com.aliyun.odps.storage.write

Class DeltaTableRecordWriter

java.lang.Object

com.aliyun.odps.storage.write.AppendTableRecordWriter

com.aliyun.odps.storage.write.DeltaTableRecordWriter

All Implemented Interfaces:

RecordWriter, Closeable, AutoCloseable

public class DeltaTableRecordWriter
extends AppendTableRecordWriter

Constructor Summary

Constructors

Constructor and Description
DeltaTableRecordWriter(TableArrowWriter arrowWriter, long recordCountPerBatch)

Method Summary

Modifier and Type	Method and Description
void	delete(Record r)
void	write(Record r)

Methods inherited from class com.aliyun.odps.storage.write.AppendTableRecordWriter

bytesWritten, close, flush, getLastRequestId, newRecord, uploadBlob

Methods inherited from class java.lang.Object

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

Constructor Detail

DeltaTableRecordWriter

public DeltaTableRecordWriter(TableArrowWriter arrowWriter,
                              long recordCountPerBatch)

Method Detail

write

public void write(Record r)

Specified by:

write in interface RecordWriter

Overrides:

write in class AppendTableRecordWriter

delete

public void delete(Record r)
            throws IOException

Throws:

IOException