public final class RawTableMasterClient extends MasterClientBase
mUseZookeeper
mAddress, mClosed, mConnected, mMode, mProtocol, mTachyonConf, RPC_MAX_NUM_RETRY
Constructor and Description |
---|
RawTableMasterClient(InetSocketAddress masterAddress,
TachyonConf tachyonConf)
Creates a new raw table master client.
|
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect() |
long |
createRawTable(TachyonURI path,
int columns,
ByteBuffer metadata)
Creates a raw table.
|
RawTableInfo |
getClientRawTableInfo(long id)
Gets the
RawTableInfo associated with the given id. |
RawTableInfo |
getClientRawTableInfo(TachyonURI path)
Gets the
RawTableInfo associated with the given path. |
protected String |
getServiceName() |
void |
updateRawTableMetadata(long tableId,
ByteBuffer metadata)
Updates the metadata of a table.
|
getAddress
afterDisconnect, close, connect, disconnect, isConnected, resetConnection
public RawTableMasterClient(InetSocketAddress masterAddress, TachyonConf tachyonConf)
masterAddress
- the master addresstachyonConf
- the Tachyon configurationprotected String getServiceName()
getServiceName
in class ClientBase
protected void afterConnect()
afterConnect
in class ClientBase
public long createRawTable(TachyonURI path, int columns, ByteBuffer metadata) throws IOException
path
- the path where the table is placedcolumns
- the number of columns in the table, must be in range (0, tachyon.max.columns)metadata
- additional metadata about the table, cannot be nullIOException
- when creation failspublic RawTableInfo getClientRawTableInfo(long id) throws IOException
RawTableInfo
associated with the given id.id
- the id of the tableIOException
- when operation failspublic RawTableInfo getClientRawTableInfo(TachyonURI path) throws IOException
RawTableInfo
associated with the given path.path
- the path of the tableIOException
- when operation failspublic void updateRawTableMetadata(long tableId, ByteBuffer metadata) throws IOException
tableId
- The id of the table to updatemetadata
- The new metadata to update the table withIOException
- when the operation failsCopyright © 2015. All Rights Reserved.