Uses of Class
org.apache.hive.hcatalog.streaming.StreamingException

Packages that use StreamingException

Package	Description
org.apache.hive.hcatalog.streaming	HCatalog Streaming API -- high level description

Uses of StreamingException in org.apache.hive.hcatalog.streaming

Subclasses of StreamingException in org.apache.hive.hcatalog.streaming

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

Methods in org.apache.hive.hcatalog.streaming that throw StreamingException

Modifier and Type	Method and Description
void	TransactionBatch.abort() Abort the currently open transaction
void	TransactionBatch.beginNextTransaction() Activate the next available transaction in the current transaction batch
void	RecordWriter.clear() Clear bufferred writes.
void	TransactionBatch.close() Close the TransactionBatch
void	RecordWriter.closeBatch() Close the RecordUpdater.
void	TransactionBatch.commit() Commit the currently open transaction
TransactionBatch	StreamingConnection.fetchTransactionBatch(int numTransactionsHint, RecordWriter writer) Acquires a new batch of transactions from Hive.
void	RecordWriter.flush() Flush records from buffer.
void	TransactionBatch.heartbeat() Issues a heartbeat to hive metastore on the current and remaining txn ids to keep them from expiring
void	RecordWriter.newBatch(Long minTxnId, Long maxTxnID) Acquire a new RecordUpdater.
void	TransactionBatch.write(byte[] record) Write record using RecordWriter
void	TransactionBatch.write(Collection<byte[]> records) Write records using RecordWriter
void	RecordWriter.write(long transactionId, byte[] record) Writes using a hive RecordUpdater

Constructors in org.apache.hive.hcatalog.streaming that throw StreamingException

Constructor and Description
DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint) Constructor.
DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, HiveConf conf) Constructor.
DelimitedInputWriter(String[] colNamesForFields, String delimiter, HiveEndPoint endPoint, HiveConf conf, char serdeSeparator) Constructor.
StrictJsonWriter(HiveEndPoint endPoint)
StrictJsonWriter(HiveEndPoint endPoint, HiveConf conf)
StrictRegexWriter(HiveEndPoint endPoint)
StrictRegexWriter(HiveEndPoint endPoint, HiveConf conf)
StrictRegexWriter(String regex, HiveEndPoint endPoint, HiveConf conf)