org.apache.hive.hcatalog.streaming

Interface RecordWriter

All Known Implementing Classes:

AbstractRecordWriter, DelimitedInputWriter, StrictJsonWriter, StrictRegexWriter

Deprecated.

as of Hive 3.0.0, replaced by RecordWriter

@Deprecated
public interface RecordWriter

Method Summary

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

Method Detail

write

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

Deprecated.

Writes using a hive RecordUpdater

Parameters:

writeId - the write ID of the table mapping to Txn in which the write occurs

record - the record to be written

Throws:

StreamingException

flush

void flush()
    throws StreamingException

Deprecated.

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

Throws:

StreamingException

clear

void clear()
    throws StreamingException

Deprecated.

Clear bufferred writes. Invoked by TransactionBatch.abort()

Throws:

StreamingException

newBatch

void newBatch(Long minWriteId,
              Long maxWriteID)
       throws StreamingException

Deprecated.

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

Throws:

StreamingException

closeBatch

void closeBatch()
         throws StreamingException

Deprecated.

Close the RecordUpdater. Invoked by TransactionBatch.close()

Throws:

StreamingException