public class MutatorClient extends Object implements Closeable
Transactions
within which ACID table mutation events can occur.
Typically this will be a large batch of delta operations.Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the client releasing any
meta store connections held. |
void |
connect()
Connects to the
meta store that will be used to manage Transaction life-cycles. |
List<AcidTable> |
getTables()
Returns the list of managed
AcidTables that can receive mutation events under the control of this
client. |
boolean |
isConnected()
Did the client connect successfully.
|
Transaction |
newTransaction()
Creates a new
Transaction by opening a transaction with the meta store . |
String |
toString() |
public void connect() throws ConnectionException
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).ConnectionException
public Transaction newTransaction() throws TransactionException
Transaction
by opening a transaction with the meta store
.TransactionException
public boolean isConnected()
public void close() throws IOException
meta store
connections held. Does not notify any open
transactions (TODO: perhaps it should?)close
in interface Closeable
close
in interface AutoCloseable
IOException
public List<AcidTable> getTables() throws ConnectionException
AcidTables
that can receive mutation events under the control of this
client.ConnectionException
Copyright © 2021 The Apache Software Foundation. All rights reserved.