org.apache.hadoop.fs.ftp

类 FTPInputStream

java.lang.Object

java.io.InputStream

org.apache.hadoop.fs.FSInputStream

org.apache.hadoop.fs.ftp.FTPInputStream

所有已实现的接口:

Closeable, AutoCloseable, PositionedReadable, Seekable

public class FTPInputStream
extends FSInputStream

构造器概要

构造器

构造器和说明
FTPInputStream(InputStream stream, org.apache.commons.net.ftp.FTPClient client, FileSystem.Statistics stats)

方法概要

方法

限定符和类型	方法和说明
void	close()
long	getPos() Return the current offset from the start of the file
void	mark(int readLimit)
boolean	markSupported()
int	read()
int	read(byte[] buf, int off, int len)
void	reset()
void	seek(long pos) Seek to the given offset from the start of the file.
boolean	seekToNewSource(long targetPos) Seeks a different copy of the data.

从类继承的方法 org.apache.hadoop.fs.FSInputStream

read, readFully, readFully

从类继承的方法 java.io.InputStream

available, read, skip

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FTPInputStream

public FTPInputStream(InputStream stream,
              org.apache.commons.net.ftp.FTPClient client,
              FileSystem.Statistics stats)

方法详细资料

getPos

public long getPos()
            throws IOException

从类复制的说明: FSInputStream

Return the current offset from the start of the file

指定者:

getPos 在接口中 Seekable

指定者:

getPos 在类中 FSInputStream

抛出:

IOException

seek

public void seek(long pos)
          throws IOException

从类复制的说明: FSInputStream

Seek to the given offset from the start of the file. The next read() will be from that location. Can't seek past the end of the file.

指定者:

seek 在接口中 Seekable

指定者:

seek 在类中 FSInputStream

抛出:

IOException

seekToNewSource

public boolean seekToNewSource(long targetPos)
                        throws IOException

从类复制的说明: FSInputStream

Seeks a different copy of the data. Returns true if found a new source, false otherwise.

指定者:

seekToNewSource 在接口中 Seekable

指定者:

seekToNewSource 在类中 FSInputStream

抛出:

IOException

read

public int read()
         throws IOException

指定者:

read 在类中 InputStream

抛出:

IOException

read

public int read(byte[] buf,
       int off,
       int len)
         throws IOException

覆盖:

read 在类中 InputStream

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 InputStream

抛出:

IOException

markSupported

public boolean markSupported()

覆盖:

markSupported 在类中 InputStream

mark

public void mark(int readLimit)

覆盖:

mark 在类中 InputStream

reset

public void reset()
           throws IOException

覆盖:

reset 在类中 InputStream

抛出:

IOException