public interface StreamingConnection extends ConnectionInfo, PartitionHandler
Modifier and Type | Method and Description |
---|---|
void |
abortTransaction()
Manually abort the opened transaction.
|
void |
beginTransaction()
Begin a transaction for writing.
|
void |
close()
Closes streaming connection.
|
void |
commitTransaction()
Commit a transaction to make the writes visible for readers.
|
ConnectionStats |
getConnectionStats()
Gets stats about the streaming connection.
|
HiveConf |
getHiveConf()
Returns hive configuration object used during connection creation.
|
void |
write(byte[] record)
Write record using RecordWriter.
|
void |
write(InputStream inputStream)
Write record using RecordWriter.
|
getAgentInfo, getMetastoreUri, getStaticPartitionValues, getTable, isDynamicPartitioning, isPartitionedTable
createPartitionIfNotExists
HiveConf getHiveConf()
void beginTransaction() throws StreamingException
StreamingException
- - if there are errors when beginning transactionvoid write(byte[] record) throws StreamingException
record
- - the data to be writtenStreamingException
- - if there are errors when writingvoid write(InputStream inputStream) throws StreamingException
inputStream
- - input stream of recordsStreamingException
- - if there are errors when writingvoid commitTransaction() throws StreamingException
StreamingException
- - if there are errors when committing the open transactionvoid abortTransaction() throws StreamingException
StreamingException
- - if there are errors when aborting the transactionvoid close()
ConnectionStats getConnectionStats()
Copyright © 2022 The Apache Software Foundation. All rights reserved.