Package | Description |
---|---|
org.apache.hive.hcatalog.streaming |
HCatalog Streaming API -- high level description
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectionError |
class |
HeartBeatFailure |
class |
ImpersonationFailed |
class |
InvalidColumn |
class |
InvalidPartition |
class |
InvalidTable |
class |
InvalidTrasactionState |
class |
PartitionCreationFailed |
class |
QueryFailedException |
class |
SerializationError |
class |
StreamingIOFailure |
class |
TransactionBatchUnAvailable |
class |
TransactionError |
Modifier and Type | Method and Description |
---|---|
void |
TransactionBatch.abort()
Deprecated.
Abort the currently open transaction.
|
void |
TransactionBatch.beginNextTransaction()
Deprecated.
Activate the next available transaction in the current transaction batch.
|
void |
RecordWriter.clear()
Deprecated.
Clear bufferred writes.
|
void |
TransactionBatch.close()
Deprecated.
Close the TransactionBatch.
|
void |
RecordWriter.closeBatch()
Deprecated.
Close the RecordUpdater.
|
void |
TransactionBatch.commit()
Deprecated.
Commit the currently open transaction.
|
TransactionBatch |
StreamingConnection.fetchTransactionBatch(int numTransactionsHint,
RecordWriter writer)
Deprecated.
Acquires a new batch of transactions from Hive.
|
void |
RecordWriter.flush()
Deprecated.
Flush records from buffer.
|
void |
TransactionBatch.heartbeat()
Deprecated.
Issues a heartbeat to hive metastore on the current and remaining txn ids
to keep them from expiring.
|
void |
RecordWriter.newBatch(Long minWriteId,
Long maxWriteID)
Deprecated.
Acquire a new RecordUpdater.
|
void |
TransactionBatch.write(byte[] record)
Deprecated.
Write record using RecordWriter.
|
void |
TransactionBatch.write(Collection<byte[]> records)
Deprecated.
Write records using RecordWriter.
|
void |
RecordWriter.write(long writeId,
byte[] record)
Deprecated.
Writes using a hive RecordUpdater
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.