Uses of Class
org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair
Packages that use IOStreamPair
Package
Description
-
Uses of IOStreamPair in org.apache.hadoop.hdfs
Methods in org.apache.hadoop.hdfs that return IOStreamPairModifier and TypeMethodDescriptionprotected IOStreamPairDFSClient.connectToDN(DatanodeInfo dn, int timeout, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken) static IOStreamPairDFSUtilClient.connectToDN(DatanodeInfo dn, int timeout, org.apache.hadoop.conf.Configuration conf, SaslDataTransferClient saslClient, SocketFactory socketFactory, boolean connectToDnViaHostname, DataEncryptionKeyFactory dekFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken) Connect to the given datanode's datantrasfer port, and return the resulting IOStreamPair. -
Uses of IOStreamPair in org.apache.hadoop.hdfs.net
Constructors in org.apache.hadoop.hdfs.net with parameters of type IOStreamPair -
Uses of IOStreamPair in org.apache.hadoop.hdfs.protocol.datatransfer.sasl
Methods in org.apache.hadoop.hdfs.protocol.datatransfer.sasl that return IOStreamPairModifier and TypeMethodDescriptionstatic IOStreamPairDataTransferSaslUtil.createStreamPair(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.crypto.CipherOption cipherOption, OutputStream out, InputStream in, boolean isServer) Create IOStreamPair ofCryptoInputStreamandCryptoOutputStreamSaslDataTransferClient.newSocketSend(Socket socket, OutputStream underlyingOut, InputStream underlyingIn, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId) Sends client SASL negotiation for a newly allocated socket if required.SaslDataTransferClient.socketSend(Socket socket, OutputStream underlyingOut, InputStream underlyingIn, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId) Sends client SASL negotiation for a socket if required.SaslDataTransferClient.socketSend(Socket socket, OutputStream underlyingOut, InputStream underlyingIn, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId, SecretKey secretKey)