org.apache.hive.streaming

Interface StreamingConnection

All Superinterfaces:

ConnectionInfo, PartitionHandler

All Known Implementing Classes:

HiveStreamingConnection

public interface StreamingConnection
extends ConnectionInfo, PartitionHandler

Method Summary

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.

Methods inherited from interface org.apache.hive.streaming.ConnectionInfo

getAgentInfo, getMetastoreUri, getStaticPartitionValues, getTable, isDynamicPartitioning, isPartitionedTable

Methods inherited from interface org.apache.hive.streaming.PartitionHandler

createPartitionIfNotExists

Method Detail

getHiveConf

HiveConf getHiveConf()

Returns hive configuration object used during connection creation.

Returns:

- hive conf

beginTransaction

void beginTransaction()
               throws StreamingException

Begin a transaction for writing.

Throws:

StreamingException - - if there are errors when beginning transaction

write

void write(byte[] record)
    throws StreamingException

Write record using RecordWriter.

Parameters:

record - - the data to be written

Throws:

StreamingException - - if there are errors when writing

write

void write(InputStream inputStream)
    throws StreamingException

Write record using RecordWriter.

Parameters:

inputStream - - input stream of records

Throws:

StreamingException - - if there are errors when writing

commitTransaction

void commitTransaction()
                throws StreamingException

Commit a transaction to make the writes visible for readers.

Throws:

StreamingException - - if there are errors when committing the open transaction

abortTransaction

void abortTransaction()
               throws StreamingException

Manually abort the opened transaction.

Throws:

StreamingException - - if there are errors when aborting the transaction

close

void close()

Closes streaming connection.

getConnectionStats

ConnectionStats getConnectionStats()

Gets stats about the streaming connection.

Returns:

- connection stats