Uses of Class
org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier

Packages that use BlockTokenIdentifier

Package	Description
org.apache.hadoop.hdfs
org.apache.hadoop.hdfs.client.impl	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.hadoop.hdfs.protocol	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.hadoop.hdfs.protocol.datatransfer
org.apache.hadoop.hdfs.protocol.datatransfer.sasl
org.apache.hadoop.hdfs.protocolPB
org.apache.hadoop.hdfs.security.token.block

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs

Fields in org.apache.hadoop.hdfs with type parameters of type BlockTokenIdentifier

Modifier and Type	Field	Description
protected org.apache.hadoop.security.token.Token<BlockTokenIdentifier>	DataStreamer.accessToken

Method parameters in org.apache.hadoop.hdfs with type arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
protected IOStreamPair	DFSClient.connectToDN(DatanodeInfo dn, int timeout, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken)
static IOStreamPair	DFSUtilClient.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.
Peer	DFSClient.newConnectedPeer(InetSocketAddress addr, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId)
Peer	RemotePeerFactory.newConnectedPeer(InetSocketAddress addr, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId)
static Peer	DFSUtilClient.peerFromSocketAndKey(SaslDataTransferClient saslClient, Socket s, DataEncryptionKeyFactory keyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, DatanodeID datanodeId, int socketTimeoutMs)

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs.client.impl

Method parameters in org.apache.hadoop.hdfs.client.impl with type arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
static BlockReader	BlockReaderRemote.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.
BlockReaderFactory	BlockReaderFactory.setBlockToken(org.apache.hadoop.security.token.Token<BlockTokenIdentifier> token)

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs.protocol

Methods in org.apache.hadoop.hdfs.protocol that return types with arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
org.apache.hadoop.security.token.Token<BlockTokenIdentifier>	LocatedBlock.getBlockToken()
org.apache.hadoop.security.token.Token<BlockTokenIdentifier>[]	LocatedStripedBlock.getBlockTokens()
org.apache.hadoop.security.token.Token<BlockTokenIdentifier>[]	StripedBlockInfo.getBlockTokens()

Method parameters in org.apache.hadoop.hdfs.protocol with type arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
BlockLocalPathInfo	ClientDatanodeProtocol.getBlockLocalPathInfo(ExtendedBlock block, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> token)	Retrieves the path names of the block file and metadata file stored on the local file system.
void	LocatedBlock.setBlockToken(org.apache.hadoop.security.token.Token<BlockTokenIdentifier> token)

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs.protocol.datatransfer

Method parameters in org.apache.hadoop.hdfs.protocol.datatransfer with type arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
void	DataTransferProtocol.blockChecksum(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, BlockChecksumOptions blockChecksumOptions)	Get block checksum (MD5 of CRC32).
void	Sender.blockChecksum(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, BlockChecksumOptions blockChecksumOptions)
void	DataTransferProtocol.blockGroupChecksum(StripedBlockInfo stripedBlockInfo, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, long requestedNumBytes, BlockChecksumOptions blockChecksumOptions)	Get striped block group checksum (MD5 of CRC32).
void	Sender.blockGroupChecksum(StripedBlockInfo stripedBlockInfo, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, long requestedNumBytes, BlockChecksumOptions blockChecksumOptions)
void	DataTransferProtocol.copyBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken)	Copy a block.
void	Sender.copyBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken)
void	DataTransferProtocol.readBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, long blockOffset, long length, boolean sendChecksum, CachingStrategy cachingStrategy)	Read a block.
void	Sender.readBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, long blockOffset, long length, boolean sendChecksum, CachingStrategy cachingStrategy)
void	DataTransferProtocol.replaceBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String delHint, DatanodeInfo source, String storageId)	Receive a block from a source datanode and then notifies the namenode to remove the copy from the original datanode.
void	Sender.replaceBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String delHint, DatanodeInfo source, String storageId)
void	DataTransferProtocol.requestShortCircuitFds(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, ShortCircuitShm.SlotId slotId, int maxVersion, boolean supportsReceiptVerification)	Request short circuit access file descriptors from a DataNode.
void	Sender.requestShortCircuitFds(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, ShortCircuitShm.SlotId slotId, int maxVersion, boolean supportsReceiptVerification)
void	DataTransferProtocol.transferBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, String[] targetStorageIDs)	Transfer a block to another datanode.
void	Sender.transferBlock(ExtendedBlock blk, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, String[] targetStorageIds)
void	DataTransferProtocol.writeBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, DatanodeInfo source, BlockConstructionStage stage, int pipelineSize, long minBytesRcvd, long maxBytesRcvd, long latestGenerationStamp, org.apache.hadoop.util.DataChecksum requestedChecksum, CachingStrategy cachingStrategy, boolean allowLazyPersist, boolean pinning, boolean[] targetPinnings, String storageID, String[] targetStorageIDs)	Write a block to a datanode pipeline.
void	Sender.writeBlock(ExtendedBlock blk, org.apache.hadoop.fs.StorageType storageType, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> blockToken, String clientName, DatanodeInfo[] targets, org.apache.hadoop.fs.StorageType[] targetStorageTypes, DatanodeInfo source, BlockConstructionStage stage, int pipelineSize, long minBytesRcvd, long maxBytesRcvd, long latestGenerationStamp, org.apache.hadoop.util.DataChecksum requestedChecksum, CachingStrategy cachingStrategy, boolean allowLazyPersist, boolean pinning, boolean[] targetPinnings, String storageId, String[] targetStorageIds)

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs.protocol.datatransfer.sasl

Method parameters in org.apache.hadoop.hdfs.protocol.datatransfer.sasl with type arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
IOStreamPair	SaslDataTransferClient.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.
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.
IOStreamPair	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.
IOStreamPair	SaslDataTransferClient.socketSend(Socket socket, OutputStream underlyingOut, InputStream underlyingIn, DataEncryptionKeyFactory encryptionKeyFactory, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> accessToken, DatanodeID datanodeId, SecretKey secretKey)

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs.protocolPB

Methods in org.apache.hadoop.hdfs.protocolPB that return types with arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
static org.apache.hadoop.security.token.Token<BlockTokenIdentifier>	PBHelperClient.convert(org.apache.hadoop.security.proto.SecurityProtos.TokenProto blockToken)
static org.apache.hadoop.security.token.Token<BlockTokenIdentifier>[]	PBHelperClient.convertTokens(List<org.apache.hadoop.security.proto.SecurityProtos.TokenProto> tokenProtos)

Methods in org.apache.hadoop.hdfs.protocolPB with parameters of type BlockTokenIdentifier

Modifier and Type	Method	Description
static org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.BlockTokenSecretProto	PBHelperClient.convert(BlockTokenIdentifier blockTokenSecret)

Method parameters in org.apache.hadoop.hdfs.protocolPB with type arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
BlockLocalPathInfo	ClientDatanodeProtocolTranslatorPB.getBlockLocalPathInfo(ExtendedBlock block, org.apache.hadoop.security.token.Token<BlockTokenIdentifier> token)

Uses of BlockTokenIdentifier in org.apache.hadoop.hdfs.security.token.block

Methods in org.apache.hadoop.hdfs.security.token.block that return types with arguments of type BlockTokenIdentifier

Modifier and Type	Method	Description
org.apache.hadoop.security.token.Token<BlockTokenIdentifier>	BlockTokenSelector.selectToken(org.apache.hadoop.io.Text service, Collection<org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>> tokens)