Uses of Interface
org.apache.hadoop.hdfs.net.Peer
Packages that use Peer
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of Peer in org.apache.hadoop.hdfs
Methods in org.apache.hadoop.hdfs that return PeerModifier and TypeMethodDescriptionPeerCache.get(DatanodeID dnId, boolean isDomain) Get a cached peer connected to the given DataNode.DFSClient.newConnectedPeer(InetSocketAddress addr, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId) RemotePeerFactory.newConnectedPeer(InetSocketAddress addr, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId) static PeerDFSUtilClient.peerFromSocket(Socket socket) static PeerDFSUtilClient.peerFromSocketAndKey(SaslDataTransferClient saslClient, Socket s, DataEncryptionKeyFactory keyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId, int socketTimeoutMs) Methods in org.apache.hadoop.hdfs with parameters of type PeerModifier and TypeMethodDescriptionvoidPeerCache.put(DatanodeID dnId, Peer peer) Give an unused socket to the cache. -
Uses of Peer in org.apache.hadoop.hdfs.client.impl
Methods in org.apache.hadoop.hdfs.client.impl that return PeerMethods in org.apache.hadoop.hdfs.client.impl with parameters of type PeerModifier and TypeMethodDescriptionstatic BlockReaderBlockReaderRemote.newBlockReader(String file, ExtendedBlock block, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, long startOffset, long len, boolean verifyChecksum, String clientName, Peer peer, DatanodeID datanodeID, PeerCache peerCache, CachingStrategy cachingStrategy, int networkDistance, org.apache.hadoop.conf.Configuration configuration) Create a new BlockReader specifically to satisfy a read.Constructors in org.apache.hadoop.hdfs.client.impl with parameters of type PeerModifierConstructorDescriptionprotectedBlockReaderRemote(String file, long blockId, org.apache.hadoop.util.DataChecksum checksum, boolean verifyChecksum, long startOffset, long firstChunkOffset, long bytesToRead, Peer peer, DatanodeID datanodeID, PeerCache peerCache, int networkDistance) -
Uses of Peer in org.apache.hadoop.hdfs.net
Classes in org.apache.hadoop.hdfs.net that implement PeerModifier and TypeClassDescriptionclassRepresents a peer that we communicate with by using a basic Socket that has no associated Channel.classRepresents a peer that we communicate with by using blocking I/O on a UNIX domain socket.classRepresents a peer that we communicate with by using an encrypted communications medium.classRepresents a peer that we communicate with by using non-blocking I/O on a Socket.Constructors in org.apache.hadoop.hdfs.net with parameters of type Peer -
Uses of Peer in org.apache.hadoop.hdfs.protocol.datatransfer.sasl
Methods in org.apache.hadoop.hdfs.protocol.datatransfer.sasl that return PeerModifier and TypeMethodDescriptionSaslDataTransferClient.peerSend(Peer peer, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId) Sends client SASL negotiation for a peer if required.Methods in org.apache.hadoop.hdfs.protocol.datatransfer.sasl with parameters of type PeerModifier and TypeMethodDescriptionstatic InetAddressDataTransferSaslUtil.getPeerAddress(Peer peer) Returns InetAddress from peer.SaslDataTransferClient.peerSend(Peer peer, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId) Sends client SASL negotiation for a peer if required.