Index
All Classes and Interfaces|All Packages|Constant Field Values
B
- build() - Method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient.GrpcClientBuilder
C
- close() - Method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient
-
Shutdown the communication channel gracefully, wait for 5 seconds before it is enforced.
- convertFrom(B) - Method in interface org.apache.hadoop.yarn.csi.translator.ProtoTranslator
-
Convert message from type B to type A.
- convertFrom(Csi.GetPluginInfoResponse) - Method in class org.apache.hadoop.yarn.csi.translator.GetPluginInfoResponseProtoTranslator
- convertFrom(Csi.NodePublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.translator.NodePublishVolumeRequestProtoTranslator
- convertFrom(Csi.NodeUnpublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.translator.NodeUnpublishVolumeRequestProtoTranslator
- convertFrom(Csi.ValidateVolumeCapabilitiesRequest) - Method in class org.apache.hadoop.yarn.csi.translator.ValidateVolumeCapabilitiesRequestProtoTranslator
- convertFrom(Csi.ValidateVolumeCapabilitiesResponse) - Method in class org.apache.hadoop.yarn.csi.translator.ValidationVolumeCapabilitiesResponseProtoTranslator
- convertTo(A) - Method in interface org.apache.hadoop.yarn.csi.translator.ProtoTranslator
-
Convert message from type A to type B.
- convertTo(GetPluginInfoResponse) - Method in class org.apache.hadoop.yarn.csi.translator.GetPluginInfoResponseProtoTranslator
- convertTo(NodePublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.translator.NodePublishVolumeRequestProtoTranslator
- convertTo(NodeUnpublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.translator.NodeUnpublishVolumeRequestProtoTranslator
- convertTo(ValidateVolumeCapabilitiesRequest) - Method in class org.apache.hadoop.yarn.csi.translator.ValidateVolumeCapabilitiesRequestProtoTranslator
- convertTo(ValidateVolumeCapabilitiesResponse) - Method in class org.apache.hadoop.yarn.csi.translator.ValidationVolumeCapabilitiesResponseProtoTranslator
- createControllerBlockingStub() - Method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient
-
Creates a blocking stub for CSI controller plugin on the given channel.
- createIdentityBlockingStub() - Method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient
-
Creates a blocking stub for CSI identity plugin on the given channel.
- createNodeBlockingStub() - Method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient
-
Creates a blocking stub for CSI node plugin on the given channel.
- CsiAdaptorFactory - Class in org.apache.hadoop.yarn.csi.adaptor
-
Desired csi-adaptor implementation is configurable, default to CsiAdaptorProtocolService.
- CsiAdaptorProtocolService - Class in org.apache.hadoop.yarn.csi.adaptor
-
This is a Hadoop RPC server, we uses the Hadoop RPC framework here because we need to stick to the security model current Hadoop supports.
- CsiAdaptorProtocolService(CsiAdaptorPlugin) - Constructor for class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- CsiAdaptorServices - Class in org.apache.hadoop.yarn.csi.adaptor
-
NM manages csi-adaptors as a single NM AUX service, this service manages a set of rpc services and each of them serves one particular csi-driver.
- CsiAdaptorServices() - Constructor for class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
- CsiClient - Interface in org.apache.hadoop.yarn.csi.client
-
General interface for a CSI client.
- CsiClientImpl - Class in org.apache.hadoop.yarn.csi.client
-
A CSI client implementation that communicates with a CSI driver via unix domain socket.
- CsiClientImpl(String) - Constructor for class org.apache.hadoop.yarn.csi.client.CsiClientImpl
- CsiGrpcClient - Class in org.apache.hadoop.yarn.csi.client
-
A CSI gRPC client, it connects a CSI driver via a given unix domain socket.
- CsiGrpcClient.GrpcClientBuilder - Class in org.apache.hadoop.yarn.csi.client
-
The Grpc Client builder.
D
- DefaultCsiAdaptorImpl - Class in org.apache.hadoop.yarn.csi.adaptor
-
The default implementation of csi-driver-adaptor service.
- DefaultCsiAdaptorImpl() - Constructor for class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
G
- getAdaptor(String, Configuration) - Static method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorFactory
-
Load csi-driver-adaptor from configuration.
- getDriverName() - Method in class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
- getMetaData() - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
- getPluginInfo() - Method in interface org.apache.hadoop.yarn.csi.client.CsiClient
-
Gets some basic info about the CSI plugin, including the driver name, version and optionally some manifest info.
- getPluginInfo() - Method in class org.apache.hadoop.yarn.csi.client.CsiClientImpl
- getPluginInfo(GetPluginInfoRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- getPluginInfo(GetPluginInfoRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
- GetPluginInfoResponseProtoTranslator<A,
B> - Class in org.apache.hadoop.yarn.csi.translator -
Protobuf message translator for GetPluginInfoResponse and Csi.GetPluginInfoResponse.
- GetPluginInfoResponseProtoTranslator() - Constructor for class org.apache.hadoop.yarn.csi.translator.GetPluginInfoResponseProtoTranslator
- getSocketAddress(String) - Static method in class org.apache.hadoop.yarn.csi.utils.GrpcHelper
- getTranslator(Class<A>, Class<B>) - Static method in class org.apache.hadoop.yarn.csi.translator.ProtoTranslatorFactory
-
Get a
ProtoTranslatorbased on the given input message types. - GrpcClientBuilder() - Constructor for class org.apache.hadoop.yarn.csi.client.CsiGrpcClient.GrpcClientBuilder
- GrpcHelper - Class in org.apache.hadoop.yarn.csi.utils
-
Helper classes for gRPC utility functions.
I
- init(String, Configuration) - Method in class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
- initializeApplication(ApplicationInitializationContext) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
N
- newBuilder() - Static method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient
- nodePublishVolume(Csi.NodePublishVolumeRequest) - Method in interface org.apache.hadoop.yarn.csi.client.CsiClient
- nodePublishVolume(Csi.NodePublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.client.CsiClientImpl
- nodePublishVolume(NodePublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- nodePublishVolume(NodePublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
- NodePublishVolumeRequestProtoTranslator<A,
B> - Class in org.apache.hadoop.yarn.csi.translator -
This class helps to transform a YARN side NodePublishVolumeRequest to corresponding CSI protocol message.
- NodePublishVolumeRequestProtoTranslator() - Constructor for class org.apache.hadoop.yarn.csi.translator.NodePublishVolumeRequestProtoTranslator
- nodeUnpublishVolume(Csi.NodeUnpublishVolumeRequest) - Method in interface org.apache.hadoop.yarn.csi.client.CsiClient
- nodeUnpublishVolume(Csi.NodeUnpublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.client.CsiClientImpl
- nodeUnpublishVolume(NodeUnpublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- nodeUnpublishVolume(NodeUnpublishVolumeRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
- NodeUnpublishVolumeRequestProtoTranslator<A,
B> - Class in org.apache.hadoop.yarn.csi.translator -
This class helps to transform a YARN side NodeUnpublishVolumeRequest to corresponding CSI protocol message.
- NodeUnpublishVolumeRequestProtoTranslator() - Constructor for class org.apache.hadoop.yarn.csi.translator.NodeUnpublishVolumeRequestProtoTranslator
O
- org.apache.hadoop.yarn.csi - package org.apache.hadoop.yarn.csi
-
This package contains classes for CSI.
- org.apache.hadoop.yarn.csi.adaptor - package org.apache.hadoop.yarn.csi.adaptor
-
This package contains CSI adaptor classes.
- org.apache.hadoop.yarn.csi.client - package org.apache.hadoop.yarn.csi.client
-
This package contains CSI client classes.
- org.apache.hadoop.yarn.csi.translator - package org.apache.hadoop.yarn.csi.translator
-
This package contains classes for protocol translation between YARN and CSI.
- org.apache.hadoop.yarn.csi.utils - package org.apache.hadoop.yarn.csi.utils
-
This package contains utility classes for CSI.
P
- ProtoTranslator<A,
B> - Interface in org.apache.hadoop.yarn.csi.translator -
ProtoTranslator converts a YARN side message to CSI proto message and vice versa.
- ProtoTranslatorFactory - Class in org.apache.hadoop.yarn.csi.translator
-
Factory class to get desired proto transformer instance.
S
- serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
- serviceStart() - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- serviceStart() - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
- serviceStop() - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- serviceStop() - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
- setDomainSocketAddress(SocketAddress) - Method in class org.apache.hadoop.yarn.csi.client.CsiGrpcClient.GrpcClientBuilder
- stopApplication(ApplicationTerminationContext) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorServices
U
- UNIX_DOMAIN_SOCKET_PREFIX - Static variable in class org.apache.hadoop.yarn.csi.utils.GrpcHelper
V
- validateVolumeCapabilities(Csi.ValidateVolumeCapabilitiesRequest) - Method in interface org.apache.hadoop.yarn.csi.client.CsiClient
- validateVolumeCapabilities(Csi.ValidateVolumeCapabilitiesRequest) - Method in class org.apache.hadoop.yarn.csi.client.CsiClientImpl
- ValidateVolumeCapabilitiesRequestProtoTranslator<A,
B> - Class in org.apache.hadoop.yarn.csi.translator -
Proto message translator for ValidateVolumeCapabilitiesRequest.
- ValidateVolumeCapabilitiesRequestProtoTranslator() - Constructor for class org.apache.hadoop.yarn.csi.translator.ValidateVolumeCapabilitiesRequestProtoTranslator
- validateVolumeCapacity(ValidateVolumeCapabilitiesRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.CsiAdaptorProtocolService
- validateVolumeCapacity(ValidateVolumeCapabilitiesRequest) - Method in class org.apache.hadoop.yarn.csi.adaptor.DefaultCsiAdaptorImpl
- ValidationVolumeCapabilitiesResponseProtoTranslator<A,
B> - Class in org.apache.hadoop.yarn.csi.translator -
Proto message translator for ValidateVolumeCapabilitiesResponse.
- ValidationVolumeCapabilitiesResponseProtoTranslator() - Constructor for class org.apache.hadoop.yarn.csi.translator.ValidationVolumeCapabilitiesResponseProtoTranslator
All Classes and Interfaces|All Packages|Constant Field Values