alluxio.thrift

Class LineageMasterClientService.Client

java.lang.Object

org.apache.thrift.TServiceClient

alluxio.thrift.AlluxioService.Client

alluxio.thrift.LineageMasterClientService.Client

All Implemented Interfaces:

AlluxioService.Iface, LineageMasterClientService.Iface

Enclosing class:

LineageMasterClientService

public static class LineageMasterClientService.Client
extends AlluxioService.Client
implements LineageMasterClientService.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LineageMasterClientService.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
Client(org.apache.thrift.protocol.TProtocol prot)
Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

Method Summary

Modifier and Type	Method and Description
CreateLineageTResponse	createLineage(List<String> inputFiles, List<String> outputFiles, CommandLineJobInfo job, CreateLineageTOptions options) Creates a lineage and returns the lineage id.
DeleteLineageTResponse	deleteLineage(long lineageId, boolean cascade, DeleteLineageTOptions options) Deletes a lineage and returns whether the deletion succeeded.
GetLineageInfoListTResponse	getLineageInfoList(GetLineageInfoListTOptions options) Returns a list of existing lineages.
CreateLineageTResponse	recv_createLineage()
DeleteLineageTResponse	recv_deleteLineage()
GetLineageInfoListTResponse	recv_getLineageInfoList()
ReinitializeFileTResponse	recv_reinitializeFile()
ReportLostFileTResponse	recv_reportLostFile()
ReinitializeFileTResponse	reinitializeFile(String path, long blockSizeBytes, long ttl, TTtlAction ttlAction, ReinitializeFileTOptions options) Reinitializes a file.
ReportLostFileTResponse	reportLostFile(String path, ReportLostFileTOptions options) Reports file as lost.
void	send_createLineage(List<String> inputFiles, List<String> outputFiles, CommandLineJobInfo job, CreateLineageTOptions options)
void	send_deleteLineage(long lineageId, boolean cascade, DeleteLineageTOptions options)
void	send_getLineageInfoList(GetLineageInfoListTOptions options)
void	send_reinitializeFile(String path, long blockSizeBytes, long ttl, TTtlAction ttlAction, ReinitializeFileTOptions options)
void	send_reportLostFile(String path, ReportLostFileTOptions options)

Methods inherited from class alluxio.thrift.AlluxioService.Client

getServiceVersion, recv_getServiceVersion, send_getServiceVersion

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway

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.Iface

getServiceVersion

Constructor Detail

Client

public Client(org.apache.thrift.protocol.TProtocol prot)

Client

public Client(org.apache.thrift.protocol.TProtocol iprot,
              org.apache.thrift.protocol.TProtocol oprot)

Method Detail

createLineage

public CreateLineageTResponse createLineage(List<String> inputFiles,
                                            List<String> outputFiles,
                                            CommandLineJobInfo job,
                                            CreateLineageTOptions options)
                                     throws AlluxioTException,
                                            org.apache.thrift.TException

Description copied from interface: LineageMasterClientService.Iface

Creates a lineage and returns the lineage id.

Specified by:

createLineage in interface LineageMasterClientService.Iface

Parameters:

inputFiles - the list of input files

outputFiles - the list of output files

job - the command line job info

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_createLineage

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

Throws:

org.apache.thrift.TException

recv_createLineage

public CreateLineageTResponse recv_createLineage()
                                          throws AlluxioTException,
                                                 org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

deleteLineage

public DeleteLineageTResponse deleteLineage(long lineageId,
                                            boolean cascade,
                                            DeleteLineageTOptions options)
                                     throws AlluxioTException,
                                            org.apache.thrift.TException

Description copied from interface: LineageMasterClientService.Iface

Deletes a lineage and returns whether the deletion succeeded.

Specified by:

deleteLineage in interface LineageMasterClientService.Iface

Parameters:

lineageId - the lineage id

cascade - whether to delete the lineage in cascade

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_deleteLineage

public void send_deleteLineage(long lineageId,
                               boolean cascade,
                               DeleteLineageTOptions options)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_deleteLineage

public DeleteLineageTResponse recv_deleteLineage()
                                          throws AlluxioTException,
                                                 org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getLineageInfoList

public GetLineageInfoListTResponse getLineageInfoList(GetLineageInfoListTOptions options)
                                               throws AlluxioTException,
                                                      org.apache.thrift.TException

Description copied from interface: LineageMasterClientService.Iface

Returns a list of existing lineages.

Specified by:

getLineageInfoList in interface LineageMasterClientService.Iface

Parameters:

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_getLineageInfoList

public void send_getLineageInfoList(GetLineageInfoListTOptions options)
                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getLineageInfoList

public GetLineageInfoListTResponse recv_getLineageInfoList()
                                                    throws AlluxioTException,
                                                           org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

reinitializeFile

public ReinitializeFileTResponse reinitializeFile(String path,
                                                  long blockSizeBytes,
                                                  long ttl,
                                                  TTtlAction ttlAction,
                                                  ReinitializeFileTOptions options)
                                           throws AlluxioTException,
                                                  org.apache.thrift.TException

Description copied from interface: LineageMasterClientService.Iface

Reinitializes a file. Returns the id of the reinitialized file when the file is lost or not completed, -1 otherwise.

Specified by:

reinitializeFile in interface LineageMasterClientService.Iface

Parameters:

path - the path of the file

blockSizeBytes - block size in bytes

ttl - time to live

ttlAction - expiry action

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_reinitializeFile

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

Throws:

org.apache.thrift.TException

recv_reinitializeFile

public ReinitializeFileTResponse recv_reinitializeFile()
                                                throws AlluxioTException,
                                                       org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

reportLostFile

public ReportLostFileTResponse reportLostFile(String path,
                                              ReportLostFileTOptions options)
                                       throws AlluxioTException,
                                              org.apache.thrift.TException

Description copied from interface: LineageMasterClientService.Iface

Reports file as lost.

Specified by:

reportLostFile in interface LineageMasterClientService.Iface

Parameters:

path - the path of the file

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_reportLostFile

public void send_reportLostFile(String path,
                                ReportLostFileTOptions options)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_reportLostFile

public ReportLostFileTResponse recv_reportLostFile()
                                            throws AlluxioTException,
                                                   org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException