org.apache.hive.hcatalog.streaming

Interface TransactionBatch

Deprecated.

as of Hive 3.0.0, replaced by HiveStreamingConnection

@Deprecated
public interface TransactionBatch

Represents a set of Transactions returned by Hive. Supports opening, writing to and commiting/aborting each transaction. The interface is designed to ensure transactions in a batch are used up sequentially. To stream to the same HiveEndPoint concurrently, create separate StreamingConnections. Note on thread safety: At most 2 threads can run through a given TransactionBatch at the same time. One thread may call heartbeat() and the other all other methods. Violating this may result in "out of sequence response".

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TransactionBatch.TxnState Deprecated.

Method Summary

Modifier and Type	Method and Description
void	abort() Deprecated. Abort the currently open transaction.
void	beginNextTransaction() Deprecated. Activate the next available transaction in the current transaction batch.
void	close() Deprecated. Close the TransactionBatch.
void	commit() Deprecated. Commit the currently open transaction.
TransactionBatch.TxnState	getCurrentTransactionState() Deprecated. get state of current transaction.
Long	getCurrentTxnId() Deprecated. Get Id of currently open transaction.
Long	getCurrentWriteId() Deprecated. Get write Id mapping to currently open transaction.
void	heartbeat() Deprecated. Issues a heartbeat to hive metastore on the current and remaining txn ids to keep them from expiring.
boolean	isClosed() Deprecated.
int	remainingTransactions() Deprecated. Remaining transactions are the ones that are not committed or aborted or open.
void	write(byte[] record) Deprecated. Write record using RecordWriter.
void	write(Collection<byte[]> records) Deprecated. Write records using RecordWriter.

Method Detail

beginNextTransaction

void beginNextTransaction()
                   throws StreamingException,
                          InterruptedException

Deprecated.

Activate the next available transaction in the current transaction batch.

Throws:

StreamingException - if not able to switch to next Txn

InterruptedException - if call in interrupted

getCurrentTxnId

Long getCurrentTxnId()

Deprecated.

Get Id of currently open transaction.

Returns:

transaction id

getCurrentWriteId

Long getCurrentWriteId()

Deprecated.

Get write Id mapping to currently open transaction.

Returns:

write id

getCurrentTransactionState

TransactionBatch.TxnState getCurrentTransactionState()

Deprecated.

get state of current transaction.

commit

void commit()
     throws StreamingException,
            InterruptedException

Deprecated.

Commit the currently open transaction.

Throws:

StreamingException - if there are errors committing

InterruptedException - if call in interrupted

abort

void abort()
    throws StreamingException,
           InterruptedException

Deprecated.

Abort the currently open transaction.

Throws:

StreamingException - if there are errors

InterruptedException - if call in interrupted

remainingTransactions

int remainingTransactions()

Deprecated.

Remaining transactions are the ones that are not committed or aborted or open. Current open transaction is not considered part of remaining txns.

Returns:

number of transactions remaining this batch.

write

void write(byte[] record)
    throws StreamingException,
           InterruptedException

Deprecated.

Write record using RecordWriter.

Parameters:

record - the data to be written

Throws:

StreamingException - if there are errors when writing

InterruptedException - if call in interrupted

write

void write(Collection<byte[]> records)
    throws StreamingException,
           InterruptedException

Deprecated.

Write records using RecordWriter.

Throws:

StreamingException - if there are errors when writing

InterruptedException - if call in interrupted

heartbeat

void heartbeat()
        throws StreamingException

Deprecated.

Issues a heartbeat to hive metastore on the current and remaining txn ids to keep them from expiring.

Throws:

StreamingException - if there are errors

close

void close()
    throws StreamingException,
           InterruptedException

Deprecated.

Close the TransactionBatch.

Throws:

StreamingException - if there are errors closing batch

InterruptedException - if call in interrupted

isClosed

boolean isClosed()

Deprecated.