RecordWriter
@Deprecated public interface RecordWriter
Modifier and Type | Method and Description |
---|---|
void |
clear()
Deprecated.
Clear bufferred writes.
|
void |
closeBatch()
Deprecated.
Close the RecordUpdater.
|
void |
flush()
Deprecated.
Flush records from buffer.
|
void |
newBatch(Long minWriteId,
Long maxWriteID)
Deprecated.
Acquire a new RecordUpdater.
|
void |
write(long writeId,
byte[] record)
Deprecated.
Writes using a hive RecordUpdater
|
void write(long writeId, byte[] record) throws StreamingException
writeId
- the write ID of the table mapping to Txn in which the write occursrecord
- the record to be writtenStreamingException
void flush() throws StreamingException
StreamingException
void clear() throws StreamingException
StreamingException
void newBatch(Long minWriteId, Long maxWriteID) throws StreamingException
StreamingException
void closeBatch() throws StreamingException
StreamingException
Copyright © 2022 The Apache Software Foundation. All rights reserved.