org.apache.hive.hcatalog.streaming.mutate.client

Class MutatorClient

java.lang.Object

org.apache.hive.hcatalog.streaming.mutate.client.MutatorClient

All Implemented Interfaces:

Closeable, AutoCloseable

Deprecated.

as of Hive 3.0.0

@Deprecated
public class MutatorClient
extends Object
implements Closeable

Responsible for orchestrating Transactions within which ACID table mutation events can occur. Typically this will be a large batch of delta operations.

Method Summary

Modifier and Type	Method and Description
void	close() Deprecated. Closes the client releasing any meta store connections held.
void	connect() Deprecated. Connects to the meta store that will be used to manage Transaction life-cycles.
List<AcidTable>	getTables() Deprecated. Returns the list of managed AcidTables that can receive mutation events under the control of this client.
boolean	isConnected() Deprecated. Did the client connect successfully.
Transaction	newTransaction() Deprecated. Creates a new Transaction by opening a transaction with the meta store.
String	toString() Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

connect

public void connect()
             throws ConnectionException

Deprecated.

Connects to the meta store that will be used to manage Transaction life-cycles. Also checks that the tables destined to receive mutation events are able to do so. The client should only hold one open transaction at any given time (TODO: enforce this).

Throws:

ConnectionException

newTransaction

public Transaction newTransaction()
                           throws TransactionException

Deprecated.

Creates a new Transaction by opening a transaction with the meta store.

Throws:

TransactionException

isConnected

public boolean isConnected()

Deprecated.

Did the client connect successfully. Note the the client may have since become disconnected.

close

public void close()
           throws IOException

Deprecated.

Closes the client releasing any meta store connections held. Does not notify any open transactions (TODO: perhaps it should?)

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getTables

public List<AcidTable> getTables()
                          throws ConnectionException

Deprecated.

Returns the list of managed AcidTables that can receive mutation events under the control of this client.

Throws:

ConnectionException

toString

public String toString()

Deprecated.

Overrides:

toString in class Object