alluxio.thrift

Class LineageMasterClientService.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

alluxio.thrift.AlluxioService.AsyncClient

alluxio.thrift.LineageMasterClientService.AsyncClient

All Implemented Interfaces:

AlluxioService.AsyncIface, LineageMasterClientService.AsyncIface

Enclosing class:

LineageMasterClientService

public static class LineageMasterClientService.AsyncClient
extends AlluxioService.AsyncClient
implements LineageMasterClientService.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LineageMasterClientService.AsyncClient.createLineage_call
static class	LineageMasterClientService.AsyncClient.deleteLineage_call
static class	LineageMasterClientService.AsyncClient.Factory
static class	LineageMasterClientService.AsyncClient.getLineageInfoList_call
static class	LineageMasterClientService.AsyncClient.reinitializeFile_call
static class	LineageMasterClientService.AsyncClient.reportLostFile_call

Nested classes/interfaces inherited from class alluxio.thrift.AlluxioService.AsyncClient

AlluxioService.AsyncClient.getServiceVersion_call

Field Summary

Fields inherited from class org.apache.thrift.async.TAsyncClient

___currentMethod, ___manager, ___protocolFactory, ___transport

Constructor Summary

Constructors

Constructor and Description
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

Method Summary

Modifier and Type	Method and Description
void	createLineage(List<String> inputFiles, List<String> outputFiles, CommandLineJobInfo job, CreateLineageTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	deleteLineage(long lineageId, boolean cascade, DeleteLineageTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getLineageInfoList(GetLineageInfoListTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	reinitializeFile(String path, long blockSizeBytes, long ttl, TTtlAction ttlAction, ReinitializeFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	reportLostFile(String path, ReportLostFileTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)

Methods inherited from class alluxio.thrift.AlluxioService.AsyncClient

getServiceVersion

Methods inherited from class org.apache.thrift.async.TAsyncClient

checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.thrift.AlluxioService.AsyncIface

getServiceVersion

Constructor Detail

AsyncClient

public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
                   org.apache.thrift.async.TAsyncClientManager clientManager,
                   org.apache.thrift.transport.TNonblockingTransport transport)

Method Detail

createLineage

public void createLineage(List<String> inputFiles,
                          List<String> outputFiles,
                          CommandLineJobInfo job,
                          CreateLineageTOptions options,
                          org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Specified by:

createLineage in interface LineageMasterClientService.AsyncIface

Throws:

org.apache.thrift.TException

deleteLineage

public void deleteLineage(long lineageId,
                          boolean cascade,
                          DeleteLineageTOptions options,
                          org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Specified by:

deleteLineage in interface LineageMasterClientService.AsyncIface

Throws:

org.apache.thrift.TException

getLineageInfoList

public void getLineageInfoList(GetLineageInfoListTOptions options,
                               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Specified by:

getLineageInfoList in interface LineageMasterClientService.AsyncIface

Throws:

org.apache.thrift.TException

reinitializeFile

public void reinitializeFile(String path,
                             long blockSizeBytes,
                             long ttl,
                             TTtlAction ttlAction,
                             ReinitializeFileTOptions options,
                             org.apache.thrift.async.AsyncMethodCallback resultHandler)
                      throws org.apache.thrift.TException

Specified by:

reinitializeFile in interface LineageMasterClientService.AsyncIface

Throws:

org.apache.thrift.TException

reportLostFile

public void reportLostFile(String path,
                           ReportLostFileTOptions options,
                           org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Specified by:

reportLostFile in interface LineageMasterClientService.AsyncIface

Throws:

org.apache.thrift.TException