@InterfaceAudience.Public @InterfaceStability.Evolving public class HdfsDataInputStream extends FSDataInputStream
FSDataInputStream
.in
Constructor and Description |
---|
HdfsDataInputStream(DFSInputStream in) |
Modifier and Type | Method and Description |
---|---|
List<LocatedBlock> |
getAllBlocks()
Get the collection of blocks that has already been located.
|
ExtendedBlock |
getCurrentBlock()
Get the block containing the target position.
|
DatanodeInfo |
getCurrentDatanode()
Get the datanode from which the stream is currently reading.
|
DFSInputStream.ReadStatistics |
getReadStatistics()
Get statistics about the reads which this DFSInputStream has done.
|
long |
getVisibleLength()
Get the visible length of the file.
|
getFileDescriptor, getPos, getWrappedStream, read, read, readFully, readFully, seek, seekToNewSource, setDropBehind, setReadahead
read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes
available, close, mark, markSupported, read, reset, skip
public HdfsDataInputStream(DFSInputStream in) throws IOException
IOException
public DatanodeInfo getCurrentDatanode()
public ExtendedBlock getCurrentBlock()
public List<LocatedBlock> getAllBlocks() throws IOException
IOException
public long getVisibleLength() throws IOException
IOException
public DFSInputStream.ReadStatistics getReadStatistics()
Copyright © 2013 Apache Software Foundation. All rights reserved.