HiveStreamingConnection
@Deprecated public interface TransactionBatch
heartbeat()
and the other all other methods.
Violating this may result in "out of sequence response".Modifier and Type | Interface and Description |
---|---|
static class |
TransactionBatch.TxnState
Deprecated.
|
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.
|
void beginNextTransaction() throws StreamingException, InterruptedException
StreamingException
- if not able to switch to next TxnInterruptedException
- if call in interruptedLong getCurrentTxnId()
Long getCurrentWriteId()
TransactionBatch.TxnState getCurrentTransactionState()
void commit() throws StreamingException, InterruptedException
StreamingException
- if there are errors committingInterruptedException
- if call in interruptedvoid abort() throws StreamingException, InterruptedException
StreamingException
- if there are errorsInterruptedException
- if call in interruptedint remainingTransactions()
void write(byte[] record) throws StreamingException, InterruptedException
record
- the data to be writtenStreamingException
- if there are errors when writingInterruptedException
- if call in interruptedvoid write(Collection<byte[]> records) throws StreamingException, InterruptedException
StreamingException
- if there are errors when writingInterruptedException
- if call in interruptedvoid heartbeat() throws StreamingException
StreamingException
- if there are errorsvoid close() throws StreamingException, InterruptedException
StreamingException
- if there are errors closing batchInterruptedException
- if call in interruptedboolean isClosed()
Copyright © 2022 The Apache Software Foundation. All rights reserved.