alluxio.worker.file

Class FileSystemWorkerClientServiceHandler

java.lang.Object

alluxio.worker.file.FileSystemWorkerClientServiceHandler

All Implemented Interfaces:

AlluxioService.Iface, FileSystemWorkerClientService.Iface

@NotThreadSafe
public final class FileSystemWorkerClientServiceHandler
extends Object
implements FileSystemWorkerClientService.Iface

Handles incoming thrift requests from a worker file system client. These RPCs are no longer supported as of 1.5.0. All methods will throw UnsupportedOperationException.

Method Summary

Modifier and Type	Method and Description
CancelUfsFileTResponse	cancelUfsFile(long sessionId, long tempUfsFileId, CancelUfsFileTOptions options) Cancels a file which has not been completed in the under file system.
CloseUfsFileTResponse	closeUfsFile(long sessionId, long tempUfsFileId, CloseUfsFileTOptions options) Closes a file in the under file system which was previously opened for reading.
CompleteUfsFileTReponse	completeUfsFile(long sessionId, long tempUfsFileId, CompleteUfsFileTOptions options) Completes a file in the under file system.
CreateUfsFileTResponse	createUfsFile(long sessionId, String ufsUri, CreateUfsFileTOptions options) Creates a file in the under file system.
GetServiceVersionTResponse	getServiceVersion(GetServiceVersionTOptions options) Returns the version of the master service.
OpenUfsFileTResponse	openUfsFile(long sessionId, String ufsUri, OpenUfsFileTOptions options) Opens an existing file in the under file system for reading.
SessionFileSystemHeartbeatTResponse	sessionFileSystemHeartbeat(long sessionId, List<Long> metrics, SessionFileSystemHeartbeatTOptions options) Local session send heartbeat to local worker to keep its state.

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

cancelUfsFile

public CancelUfsFileTResponse cancelUfsFile(long sessionId,
                                            long tempUfsFileId,
                                            CancelUfsFileTOptions options)
                                     throws AlluxioTException

Description copied from interface: FileSystemWorkerClientService.Iface

Cancels a file which has not been completed in the under file system.

Specified by:

cancelUfsFile in interface FileSystemWorkerClientService.Iface

Parameters:

sessionId - the id of the current session

tempUfsFileId - the worker specific file id of the ufs file

options - the options for canceling the file

Throws:

AlluxioTException

closeUfsFile

public CloseUfsFileTResponse closeUfsFile(long sessionId,
                                          long tempUfsFileId,
                                          CloseUfsFileTOptions options)
                                   throws AlluxioTException

Description copied from interface: FileSystemWorkerClientService.Iface

Closes a file in the under file system which was previously opened for reading.

Specified by:

closeUfsFile in interface FileSystemWorkerClientService.Iface

Parameters:

sessionId - the id of the current session

tempUfsFileId - the worker specific file id of the ufs file

options - the options for closing the file

Throws:

AlluxioTException

completeUfsFile

public CompleteUfsFileTReponse completeUfsFile(long sessionId,
                                               long tempUfsFileId,
                                               CompleteUfsFileTOptions options)
                                        throws AlluxioTException

Description copied from interface: FileSystemWorkerClientService.Iface

Completes a file in the under file system.

Specified by:

completeUfsFile in interface FileSystemWorkerClientService.Iface

Parameters:

sessionId - the id of the current session

tempUfsFileId - the worker specific file id of the ufs file

options - the options for completing the file

Throws:

AlluxioTException

createUfsFile

public CreateUfsFileTResponse createUfsFile(long sessionId,
                                            String ufsUri,
                                            CreateUfsFileTOptions options)
                                     throws AlluxioTException

Description copied from interface: FileSystemWorkerClientService.Iface

Creates a file in the under file system.

Specified by:

createUfsFile in interface FileSystemWorkerClientService.Iface

Parameters:

sessionId - the id of the current session

ufsUri - the path of the file in the ufs

options - the options for creating the file

Throws:

AlluxioTException

openUfsFile

public OpenUfsFileTResponse openUfsFile(long sessionId,
                                        String ufsUri,
                                        OpenUfsFileTOptions options)
                                 throws AlluxioTException

Description copied from interface: FileSystemWorkerClientService.Iface

Opens an existing file in the under file system for reading.

Specified by:

openUfsFile in interface FileSystemWorkerClientService.Iface

Parameters:

sessionId - the id of the current session

ufsUri - the path of the file in the ufs

options - the options for opening the file

Throws:

AlluxioTException

sessionFileSystemHeartbeat

public SessionFileSystemHeartbeatTResponse sessionFileSystemHeartbeat(long sessionId,
                                                                      List<Long> metrics,
                                                                      SessionFileSystemHeartbeatTOptions options)
                                                               throws AlluxioTException

Description copied from interface: FileSystemWorkerClientService.Iface

Local session send heartbeat to local worker to keep its state.

Specified by:

sessionFileSystemHeartbeat in interface FileSystemWorkerClientService.Iface

Parameters:

sessionId - the id of the current session

metrics - the client metrics. deprecated since 1.3.0 and will be removed in 2.0

options - the method options

Throws:

AlluxioTException