public class WebHdfsFileSystem.WebHdfsInputStream
extends org.apache.hadoop.fs.FSInputStream
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected int |
getBufferSize() |
long |
getFileLength() |
protected org.apache.hadoop.fs.Path |
getPath() |
long |
getPos() |
int |
read() |
int |
read(byte[] b,
int off,
int len) |
void |
seek(long newPos) |
boolean |
seekToNewSource(long targetPos) |
void |
setFileLength(long len) |
read, readFully, readFully, validatePositionedReadArgs
available, mark, markSupported, read, reset, skip
public int read() throws IOException
read
in class InputStream
IOException
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
IOException
public void seek(long newPos) throws IOException
seek
in interface org.apache.hadoop.fs.Seekable
seek
in class org.apache.hadoop.fs.FSInputStream
IOException
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.fs.Seekable
getPos
in class org.apache.hadoop.fs.FSInputStream
IOException
protected int getBufferSize() throws IOException
IOException
protected org.apache.hadoop.fs.Path getPath() throws IOException
IOException
public boolean seekToNewSource(long targetPos) throws IOException
seekToNewSource
in class org.apache.hadoop.fs.FSInputStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class InputStream
IOException
public void setFileLength(long len)
public long getFileLength()
Copyright © 2018 Apache Software Foundation. All Rights Reserved.