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