@InterfaceAudience.Public @InterfaceStability.Evolving public class HdfsDataInputStream extends FSDataInputStream
FSDataInputStream
.in
ABORTABLE_STREAM, DROPBEHIND, HFLUSH, HSYNC, IOSTATISTICS, IOSTATISTICS_CONTEXT, PREADBYTEBUFFER, READAHEAD, READBYTEBUFFER, UNBUFFER, VECTOREDIO
Constructor and Description |
---|
HdfsDataInputStream(org.apache.hadoop.crypto.CryptoInputStream in) |
HdfsDataInputStream(org.apache.hadoop.hdfs.DFSInputStream in) |
Modifier and Type | Method and Description |
---|---|
void |
clearReadStatistics() |
List<org.apache.hadoop.hdfs.protocol.LocatedBlock> |
getAllBlocks()
Get the collection of blocks that has already been located.
|
org.apache.hadoop.hdfs.protocol.ExtendedBlock |
getCurrentBlock()
Get the block containing the target position.
|
org.apache.hadoop.hdfs.protocol.DatanodeInfo |
getCurrentDatanode()
Get the datanode from which the stream is currently reading.
|
org.apache.hadoop.hdfs.ReadStatistics |
getReadStatistics()
Get statistics about the reads which this DFSInputStream has done.
|
long |
getVisibleLength()
Get the visible length of the file.
|
InputStream |
getWrappedStream()
Get a reference to the wrapped output stream.
|
getFileDescriptor, getIOStatistics, getPos, hasCapability, maxReadSizeForVectorReads, minSeekForVectorReads, read, read, read, read, read, readFully, readFully, readFully, readVectored, releaseBuffer, seek, seekToNewSource, setDropBehind, setReadahead, toString, unbuffer
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(org.apache.hadoop.hdfs.DFSInputStream in)
public HdfsDataInputStream(org.apache.hadoop.crypto.CryptoInputStream in)
public InputStream getWrappedStream()
getWrappedStream
in class FSDataInputStream
public org.apache.hadoop.hdfs.protocol.DatanodeInfo getCurrentDatanode()
public org.apache.hadoop.hdfs.protocol.ExtendedBlock getCurrentBlock()
public List<org.apache.hadoop.hdfs.protocol.LocatedBlock> getAllBlocks() throws IOException
IOException
public long getVisibleLength()
public org.apache.hadoop.hdfs.ReadStatistics getReadStatistics()
public void clearReadStatistics()
Copyright © 2024 Apache Software Foundation. All rights reserved.