alluxio.master.lineage

Class LineageMasterClientServiceHandler

java.lang.Object

alluxio.master.lineage.LineageMasterClientServiceHandler

All Implemented Interfaces:

AlluxioService.Iface, LineageMasterClientService.Iface

@ThreadSafe
public final class LineageMasterClientServiceHandler
extends Object
implements LineageMasterClientService.Iface

This class is a Thrift handler for lineage master RPCs invoked by an Alluxio client.

Method Summary

Modifier and Type	Method and Description
CreateLineageTResponse	createLineage(List<String> inputFiles, List<String> outputFiles, CommandLineJobInfo jobInfo, 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.
GetServiceVersionTResponse	getServiceVersion(GetServiceVersionTOptions options) Returns the version of the master service.
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.

Methods inherited from class java.lang.Object

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

Method Detail

getServiceVersion

public GetServiceVersionTResponse getServiceVersion(GetServiceVersionTOptions options)

Description copied from interface: AlluxioService.Iface

Returns the version of the master service. NOTE: The version should be updated every time a backwards incompatible API change occurs.

Specified by:

getServiceVersion in interface AlluxioService.Iface

Parameters:

options - the method options

createLineage

public CreateLineageTResponse createLineage(List<String> inputFiles,
                                            List<String> outputFiles,
                                            CommandLineJobInfo jobInfo,
                                            CreateLineageTOptions options)
                                     throws AlluxioTException

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

jobInfo - the command line job info

options - the method options

Throws:

AlluxioTException

deleteLineage

public DeleteLineageTResponse deleteLineage(long lineageId,
                                            boolean cascade,
                                            DeleteLineageTOptions options)
                                     throws AlluxioTException

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

getLineageInfoList

public GetLineageInfoListTResponse getLineageInfoList(GetLineageInfoListTOptions options)
                                               throws AlluxioTException

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

reinitializeFile

public ReinitializeFileTResponse reinitializeFile(String path,
                                                  long blockSizeBytes,
                                                  long ttl,
                                                  TTtlAction ttlAction,
                                                  ReinitializeFileTOptions options)
                                           throws AlluxioTException

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

reportLostFile

public ReportLostFileTResponse reportLostFile(String path,
                                              ReportLostFileTOptions options)
                                       throws AlluxioTException

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