Uses of Class
org.apache.hadoop.hdfs.DFSInputStream
Packages that use DFSInputStream
Package
Description
This package provides the administrative APIs for HDFS.
-
Uses of DFSInputStream in org.apache.hadoop.hdfs
Subclasses of DFSInputStream in org.apache.hadoop.hdfsModifier and TypeClassDescriptionclassDFSStripedInputStream reads from striped block groups.Methods in org.apache.hadoop.hdfs that return DFSInputStreamModifier and TypeMethodDescriptionCreate an input stream that obtains a nodelist from the namenode, and then reads from all the right places.DFSClient.open(String src, int buffersize, boolean verifyChecksum, org.apache.hadoop.fs.FileSystem.Statistics stats) Deprecated.DFSClient.open(HdfsPathHandle fd, int buffersize, boolean verifyChecksum) Create an input stream from theHdfsPathHandleif the constraints encoded fromDistributedFileSystem.createPathHandle(FileStatus, Options.HandleOpt...)are satisfied.Methods in org.apache.hadoop.hdfs with parameters of type DFSInputStreamModifier and TypeMethodDescriptionvoidLocatedBlocksRefresher.addInputStream(DFSInputStream dfsInputStream) voidDFSClient.addLocatedBlocksRefresh(DFSInputStream dfsInputStream) Adds theDFSInputStreamto theLocatedBlocksRefresher, so that the underlyingLocatedBlocksis periodically refreshed.voidDFSClient.addNodeToDeadNodeDetector(DFSInputStream dfsInputStream, DatanodeInfo datanodeInfo) Add given datanode in DeadNodeDetector.voidDeadNodeDetector.addNodeToDetect(DFSInputStream dfsInputStream, DatanodeInfo datanodeInfo) Add datanode to suspectNodes and suspectAndDeadNodes.DFSClient.createWrappedInputStream(DFSInputStream dfsis) Wraps the stream in a CryptoInputStream if the underlying file is encrypted.DFSClient.getDeadNodes(DFSInputStream dfsInputStream) If deadNodeDetectionEnabled is true, return the dead nodes that detected by all the DFSInputStreams in the same client.booleanDFSClient.isDeadNode(DFSInputStream dfsInputStream, DatanodeInfo datanodeInfo) If deadNodeDetectionEnabled is true, judgement based on whether this datanode is included or not in DeadNodeDetector.booleanLocatedBlocksRefresher.isInputStreamTracked(DFSInputStream dfsInputStream) voidLocatedBlocksRefresher.removeInputStream(DFSInputStream dfsInputStream) voidDFSClient.removeLocatedBlocksRefresh(DFSInputStream dfsInputStream) Removes theDFSInputStreamfrom theLocatedBlocksRefresher, so that the underlyingLocatedBlocksis no longer periodically refreshed.voidDeadNodeDetector.removeNodeFromDeadNodeDetector(DFSInputStream dfsInputStream, DatanodeInfo datanodeInfo) Remove suspect and dead node from suspectAndDeadNodes#dfsInputStream and local deadNodes.voidDFSClient.removeNodeFromDeadNodeDetector(DFSInputStream dfsInputStream, DatanodeInfo datanodeInfo) Remove given datanode from DeadNodeDetector.voidDFSClient.removeNodeFromDeadNodeDetector(DFSInputStream dfsInputStream, LocatedBlocks locatedBlocks) Remove datanodes that given block placed on from DeadNodeDetector.Constructors in org.apache.hadoop.hdfs with parameters of type DFSInputStream -
Uses of DFSInputStream in org.apache.hadoop.hdfs.client
Constructors in org.apache.hadoop.hdfs.client with parameters of type DFSInputStream
DFSClient.open(String, int, boolean)instead.