Package org.apache.hadoop.yarn.api.impl.pb.client

Class CsiAdaptorProtocolPBClientImpl

java.lang.Object

org.apache.hadoop.yarn.api.impl.pb.client.CsiAdaptorProtocolPBClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.yarn.api.CsiAdaptorProtocol

public class CsiAdaptorProtocolPBClientImpl
extends Object
implements org.apache.hadoop.yarn.api.CsiAdaptorProtocol, Closeable

CSI adaptor client implementation.

Constructor Summary

Constructors

Constructor	Description
CsiAdaptorProtocolPBClientImpl(long clientVersion, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	close()
org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoResponse	getPluginInfo(org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoRequest request)
org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeResponse	nodePublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeRequest request)
org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeResponse	nodeUnpublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeRequest request)
org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesResponse	validateVolumeCapacity(org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

CsiAdaptorProtocolPBClientImpl

public CsiAdaptorProtocolPBClientImpl(long clientVersion,
 InetSocketAddress addr,
 org.apache.hadoop.conf.Configuration conf)
                               throws IOException

Throws:

IOException

Method Details

getPluginInfo

public org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoResponse getPluginInfo(org.apache.hadoop.yarn.api.protocolrecords.GetPluginInfoRequest request)
                                                                               throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

getPluginInfo in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

validateVolumeCapacity

public org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesResponse validateVolumeCapacity(org.apache.hadoop.yarn.api.protocolrecords.ValidateVolumeCapabilitiesRequest request)
                                                                                                     throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

validateVolumeCapacity in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

nodePublishVolume

public org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeResponse nodePublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodePublishVolumeRequest request)
                                                                                       throws IOException,
org.apache.hadoop.yarn.exceptions.YarnException

Specified by:

nodePublishVolume in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol

Throws:

IOException

org.apache.hadoop.yarn.exceptions.YarnException

nodeUnpublishVolume

public org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeResponse nodeUnpublishVolume(org.apache.hadoop.yarn.api.protocolrecords.NodeUnpublishVolumeRequest request)
                                                                                           throws org.apache.hadoop.yarn.exceptions.YarnException,
IOException

Specified by:

nodeUnpublishVolume in interface org.apache.hadoop.yarn.api.CsiAdaptorProtocol

Throws:

org.apache.hadoop.yarn.exceptions.YarnException

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException