Package | Description |
---|---|
org.apache.hive.streaming |
HCatalog Streaming API -- high level description
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectionError |
class |
InvalidTable |
class |
InvalidTransactionState |
class |
PartitionCreationFailed |
class |
SerializationError |
class |
StreamingIOFailure |
class |
TransactionError |
Modifier and Type | Method and Description |
---|---|
void |
HiveStreamingConnection.abortTransaction() |
void |
StreamingConnection.abortTransaction()
Manually abort the opened transaction.
|
void |
HiveStreamingConnection.beginTransaction() |
void |
StreamingConnection.beginTransaction()
Begin a transaction for writing.
|
void |
RecordWriter.close()
Close the RecordUpdater.
|
void |
HiveStreamingConnection.commitTransaction() |
void |
StreamingConnection.commitTransaction()
Commit a transaction to make the writes visible for readers.
|
HiveStreamingConnection |
HiveStreamingConnection.Builder.connect()
Returning a streaming connection to hive.
|
PartitionInfo |
PartitionHandler.createPartitionIfNotExists(List<String> partitionValues)
Creates a partition if it does not exist.
|
PartitionInfo |
HiveStreamingConnection.createPartitionIfNotExists(List<String> partitionValues) |
void |
RecordWriter.flush()
Flush records from buffer.
|
void |
RecordWriter.init(StreamingConnection connection,
long minWriteId,
long maxWriteID)
Initialize record writer.
|
void |
AbstractRecordWriter.init(StreamingConnection conn,
long minWriteId,
long maxWriteId) |
void |
HiveStreamingConnection.write(byte[] record) |
void |
StreamingConnection.write(byte[] record)
Write record using RecordWriter.
|
void |
HiveStreamingConnection.write(InputStream inputStream) |
void |
StreamingConnection.write(InputStream inputStream)
Write record using RecordWriter.
|
void |
RecordWriter.write(long writeId,
byte[] record)
Writes using a hive RecordUpdater.
|
void |
AbstractRecordWriter.write(long writeId,
byte[] record) |
void |
RecordWriter.write(long writeId,
InputStream inputStream)
Writes using a hive RecordUpdater.
|
void |
AbstractRecordWriter.write(long writeId,
InputStream inputStream) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.