org.apache.hive.hcatalog.streaming

Interface RecordWriter

All Known Implementing Classes:

DelimitedInputWriter, StrictJsonWriter, StrictRegexWriter

public interface RecordWriter

Method Summary

Methods

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

Method Detail

write

void write(long transactionId,
         byte[] record)
           throws StreamingException

Writes using a hive RecordUpdater

Parameters:

transactionId - the ID of the Txn in which the write occurs

record - the record to be written

Throws:

StreamingException

flush

void flush()
           throws StreamingException

Flush records from buffer. Invoked by TransactionBatch.commit()

Throws:

StreamingException

clear

void clear()
           throws StreamingException

Clear bufferred writes. Invoked by TransactionBatch.abort()

Throws:

StreamingException

newBatch

void newBatch(Long minTxnId,
            Long maxTxnID)
              throws StreamingException

Acquire a new RecordUpdater. Invoked when StreamingConnection.fetchTransactionBatch() is called

Throws:

StreamingException

closeBatch

void closeBatch()
                throws StreamingException

Close the RecordUpdater. Invoked by TransactionBatch.close()

Throws:

StreamingException