public interface StreamingConnection
Modifier and Type | Method and Description |
---|---|
void |
close()
Close connection
|
TransactionBatch |
fetchTransactionBatch(int numTransactionsHint,
RecordWriter writer)
Acquires a new batch of transactions from Hive.
|
org.apache.hadoop.security.UserGroupInformation |
getUserGroupInformation() |
TransactionBatch fetchTransactionBatch(int numTransactionsHint, RecordWriter writer) throws ConnectionError, StreamingException, InterruptedException
numTransactionsHint
- is a hint from client indicating how many transactions client needs.writer
- Used to write record. The same writer instance can
be shared with another TransactionBatch (to the same endpoint)
only after the first TransactionBatch has been closed.
Writer will be closed when the TransactionBatch is closed.ConnectionError
InvalidPartition
StreamingException
InterruptedException
void close()
org.apache.hadoop.security.UserGroupInformation getUserGroupInformation()
null
if there is noneCopyright © 2017 The Apache Software Foundation. All rights reserved.