alluxio.thrift

Class FileSystemWorkerClientService.Client

java.lang.Object

org.apache.thrift.TServiceClient

alluxio.thrift.AlluxioService.Client

alluxio.thrift.FileSystemWorkerClientService.Client

All Implemented Interfaces:

AlluxioService.Iface, FileSystemWorkerClientService.Iface

Enclosing class:

FileSystemWorkerClientService

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileSystemWorkerClientService.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
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 ufsPath, CreateUfsFileTOptions options) Creates a file in the under file system.
OpenUfsFileTResponse	openUfsFile(long sessionId, String ufsPath, OpenUfsFileTOptions options) Opens an existing file in the under file system for reading.
CancelUfsFileTResponse	recv_cancelUfsFile()
CloseUfsFileTResponse	recv_closeUfsFile()
CompleteUfsFileTReponse	recv_completeUfsFile()
CreateUfsFileTResponse	recv_createUfsFile()
OpenUfsFileTResponse	recv_openUfsFile()
SessionFileSystemHeartbeatTResponse	recv_sessionFileSystemHeartbeat()
void	send_cancelUfsFile(long sessionId, long tempUfsFileId, CancelUfsFileTOptions options)
void	send_closeUfsFile(long sessionId, long tempUfsFileId, CloseUfsFileTOptions options)
void	send_completeUfsFile(long sessionId, long tempUfsFileId, CompleteUfsFileTOptions options)
void	send_createUfsFile(long sessionId, String ufsPath, CreateUfsFileTOptions options)
void	send_openUfsFile(long sessionId, String ufsPath, OpenUfsFileTOptions options)
void	send_sessionFileSystemHeartbeat(long sessionId, List<Long> metrics, SessionFileSystemHeartbeatTOptions options)
SessionFileSystemHeartbeatTResponse	sessionFileSystemHeartbeat(long sessionId, List<Long> metrics, SessionFileSystemHeartbeatTOptions options) Local session send heartbeat to local worker to keep its state.

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

cancelUfsFile

public CancelUfsFileTResponse cancelUfsFile(long sessionId,
                                            long tempUfsFileId,
                                            CancelUfsFileTOptions options)
                                     throws AlluxioTException,
                                            org.apache.thrift.TException

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

org.apache.thrift.TException

send_cancelUfsFile

public void send_cancelUfsFile(long sessionId,
                               long tempUfsFileId,
                               CancelUfsFileTOptions options)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_cancelUfsFile

public CancelUfsFileTResponse recv_cancelUfsFile()
                                          throws AlluxioTException,
                                                 org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

closeUfsFile

public CloseUfsFileTResponse closeUfsFile(long sessionId,
                                          long tempUfsFileId,
                                          CloseUfsFileTOptions options)
                                   throws AlluxioTException,
                                          org.apache.thrift.TException

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

org.apache.thrift.TException

send_closeUfsFile

public void send_closeUfsFile(long sessionId,
                              long tempUfsFileId,
                              CloseUfsFileTOptions options)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_closeUfsFile

public CloseUfsFileTResponse recv_closeUfsFile()
                                        throws AlluxioTException,
                                               org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

completeUfsFile

public CompleteUfsFileTReponse completeUfsFile(long sessionId,
                                               long tempUfsFileId,
                                               CompleteUfsFileTOptions options)
                                        throws AlluxioTException,
                                               org.apache.thrift.TException

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

org.apache.thrift.TException

send_completeUfsFile

public void send_completeUfsFile(long sessionId,
                                 long tempUfsFileId,
                                 CompleteUfsFileTOptions options)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_completeUfsFile

public CompleteUfsFileTReponse recv_completeUfsFile()
                                             throws AlluxioTException,
                                                    org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

createUfsFile

public CreateUfsFileTResponse createUfsFile(long sessionId,
                                            String ufsPath,
                                            CreateUfsFileTOptions options)
                                     throws AlluxioTException,
                                            org.apache.thrift.TException

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

ufsPath - the path of the file in the ufs

options - the options for creating the file

Throws:

AlluxioTException

org.apache.thrift.TException

send_createUfsFile

public void send_createUfsFile(long sessionId,
                               String ufsPath,
                               CreateUfsFileTOptions options)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_createUfsFile

public CreateUfsFileTResponse recv_createUfsFile()
                                          throws AlluxioTException,
                                                 org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

openUfsFile

public OpenUfsFileTResponse openUfsFile(long sessionId,
                                        String ufsPath,
                                        OpenUfsFileTOptions options)
                                 throws AlluxioTException,
                                        org.apache.thrift.TException

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

ufsPath - the path of the file in the ufs

options - the options for opening the file

Throws:

AlluxioTException

org.apache.thrift.TException

send_openUfsFile

public void send_openUfsFile(long sessionId,
                             String ufsPath,
                             OpenUfsFileTOptions options)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_openUfsFile

public OpenUfsFileTResponse recv_openUfsFile()
                                      throws AlluxioTException,
                                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

sessionFileSystemHeartbeat

public SessionFileSystemHeartbeatTResponse sessionFileSystemHeartbeat(long sessionId,
                                                                      List<Long> metrics,
                                                                      SessionFileSystemHeartbeatTOptions options)
                                                               throws AlluxioTException,
                                                                      org.apache.thrift.TException

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

org.apache.thrift.TException

send_sessionFileSystemHeartbeat

public void send_sessionFileSystemHeartbeat(long sessionId,
                                            List<Long> metrics,
                                            SessionFileSystemHeartbeatTOptions options)
                                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_sessionFileSystemHeartbeat

public SessionFileSystemHeartbeatTResponse recv_sessionFileSystemHeartbeat()
                                                                    throws AlluxioTException,
                                                                           org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException