public final class LineageMasterClient extends MasterClientBase
mUseZookeeper
mAddress, mClosed, mConnected, mMode, mProtocol, mTachyonConf, RPC_MAX_NUM_RETRY
Constructor and Description |
---|
LineageMasterClient(InetSocketAddress masterAddress,
TachyonConf tachyonConf)
Creates a new lineage master client.
|
Modifier and Type | Method and Description |
---|---|
protected void |
afterConnect() |
void |
asyncCompleteFile(long fileId) |
long |
createLineage(List<String> inputFiles,
List<String> outputFiles,
CommandLineJob job) |
boolean |
deleteLineage(long lineageId,
boolean cascade) |
List<LineageInfo> |
getLineageInfoList() |
protected String |
getServiceName() |
long |
reinitializeFile(String path,
long blockSizeBytes,
long ttl) |
getAddress
afterDisconnect, close, connect, disconnect, isConnected, resetConnection
public LineageMasterClient(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 createLineage(List<String> inputFiles, List<String> outputFiles, CommandLineJob job) throws IOException, TachyonException
IOException
TachyonException
public boolean deleteLineage(long lineageId, boolean cascade) throws IOException, TachyonException
IOException
TachyonException
public long reinitializeFile(String path, long blockSizeBytes, long ttl) throws IOException, TachyonException
IOException
TachyonException
public void asyncCompleteFile(long fileId) throws IOException
IOException
public List<LineageInfo> getLineageInfoList() throws IOException
IOException
Copyright © 2015. All Rights Reserved.