Uses of Class
org.apache.hadoop.hdfs.protocol.DatanodeID
Packages that use DatanodeID
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of DatanodeID in org.apache.hadoop.hdfs
Methods in org.apache.hadoop.hdfs with parameters of type DatanodeIDModifier and TypeMethodDescriptionstatic ClientDatanodeProtocolDFSUtilClient.createClientDatanodeProtocolProxy(DatanodeID datanodeid, org.apache.hadoop.conf.Configuration conf, int socketTimeout, boolean connectToDnViaHostname) CreateClientDatanodeProtocolproxy using kerberos ticketstatic ClientDatanodeProtocolDFSUtilClient.createClientDatanodeProtocolProxy(DatanodeID datanodeid, org.apache.hadoop.conf.Configuration conf, int socketTimeout, boolean connectToDnViaHostname, LocatedBlock locatedBlock) Create aClientDatanodeProtocolproxyPeerCache.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.peerFromSocketAndKey(SaslDataTransferClient saslClient, Socket s, DataEncryptionKeyFactory keyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId, int socketTimeoutMs) voidPeerCache.put(DatanodeID dnId, Peer peer) Give an unused socket to the cache. -
Uses of DatanodeID in org.apache.hadoop.hdfs.client.impl
Methods in org.apache.hadoop.hdfs.client.impl with parameters of type DatanodeIDModifier 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 DatanodeIDModifierConstructorDescriptionprotectedBlockReaderRemote(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 DatanodeID in org.apache.hadoop.hdfs.protocol
Subclasses of DatanodeID in org.apache.hadoop.hdfs.protocolModifier and TypeClassDescriptionclassThis class extends the primary identifier of a Datanode with ephemeral state, eg usage information, current administrative state, and the network location that is communicated to clients.classFields in org.apache.hadoop.hdfs.protocol declared as DatanodeIDModifier and TypeFieldDescriptionstatic final DatanodeID[]DatanodeID.EMPTY_ARRAYstatic final DatanodeIDDatanodeID.EMPTY_DATANODE_IDMethods in org.apache.hadoop.hdfs.protocol with parameters of type DatanodeIDModifier and TypeMethodDescriptionintDatanodeID.compareTo(DatanodeID that) Compare based on data transfer address.DatanodeInfo.DatanodeInfoBuilder.setNodeID(DatanodeID nodeID) voidClientProtocol.updatePipeline(String clientName, ExtendedBlock oldBlock, ExtendedBlock newBlock, DatanodeID[] newNodes, String[] newStorageIDs) Update a pipeline for a block under construction.voidDatanodeID.updateRegInfo(DatanodeID nodeReg) Update fields when a new registration request comes in.Constructors in org.apache.hadoop.hdfs.protocol with parameters of type DatanodeIDModifierConstructorDescriptionDatanodeID(String datanodeUuid, DatanodeID from) DatanodeID(DatanodeID from) protectedDatanodeInfo(DatanodeID nodeID) protectedDatanodeInfo(DatanodeID nodeID, String location) -
Uses of DatanodeID in org.apache.hadoop.hdfs.protocol.datatransfer.sasl
Methods in org.apache.hadoop.hdfs.protocol.datatransfer.sasl with parameters of type DatanodeIDModifier and TypeMethodDescriptionSaslDataTransferClient.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.peerSend(Peer peer, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId) Sends client SASL negotiation for a peer 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) -
Uses of DatanodeID in org.apache.hadoop.hdfs.protocolPB
Methods in org.apache.hadoop.hdfs.protocolPB that return DatanodeIDModifier and TypeMethodDescriptionstatic DatanodeIDPBHelperClient.convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto dn) static DatanodeID[]PBHelperClient.convert(org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[] did) Methods in org.apache.hadoop.hdfs.protocolPB with parameters of type DatanodeIDModifier and TypeMethodDescriptionstatic org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProtoPBHelperClient.convert(DatanodeID dn) static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.DatanodeIDProto[]PBHelperClient.convert(DatanodeID[] did) voidClientNamenodeProtocolTranslatorPB.updatePipeline(String clientName, ExtendedBlock oldBlock, ExtendedBlock newBlock, DatanodeID[] newNodes, String[] storageIDs) Constructors in org.apache.hadoop.hdfs.protocolPB with parameters of type DatanodeIDModifierConstructorDescriptionClientDatanodeProtocolTranslatorPB(DatanodeID datanodeid, org.apache.hadoop.conf.Configuration conf, int socketTimeout, boolean connectToDnViaHostname) Constructor.ClientDatanodeProtocolTranslatorPB(DatanodeID datanodeid, org.apache.hadoop.conf.Configuration conf, int socketTimeout, boolean connectToDnViaHostname, LocatedBlock locatedBlock)