Field Detail

• in

  private org.apache.hadoop.fs.FSDataInputStream in

• currentPath

  private org.apache.hadoop.fs.Path currentPath

• pos

  private long pos

• fileLink

  private final FileLink fileLink

• bufferSize

  private final int bufferSize

• fs

  private final org.apache.hadoop.fs.FileSystem fs

Constructor Detail

• FileLink.FileLinkInputStream

  public FileLink.FileLinkInputStream(org.apache.hadoop.fs.FileSystem fs,
                              FileLink fileLink)
                               throws IOException

  Throws:

  IOException

• FileLink.FileLinkInputStream

  public FileLink.FileLinkInputStream(org.apache.hadoop.fs.FileSystem fs,
                              FileLink fileLink,
                              int bufferSize)
                               throws IOException

  Throws:

  IOException

Method Detail

• read

  public int read()
           throws IOException

  Specified by:

  read in class InputStream

  Throws:

  IOException

• read

  public int read(byte[] b)
           throws IOException

  Overrides:

  read in class InputStream

  Throws:

  IOException

• read

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

  Overrides:

  read in class InputStream

  Throws:

  IOException

• read

  public int read(long position,
         byte[] buffer,
         int offset,
         int length)
           throws IOException

  Specified by:

  read in interface org.apache.hadoop.fs.PositionedReadable

  Throws:

  IOException

• readFully

  public void readFully(long position,
               byte[] buffer)
                 throws IOException

  Specified by:

  readFully in interface org.apache.hadoop.fs.PositionedReadable

  Throws:

  IOException

• readFully

  public void readFully(long position,
               byte[] buffer,
               int offset,
               int length)
                 throws IOException

  Specified by:

  readFully in interface org.apache.hadoop.fs.PositionedReadable

  Throws:

  IOException

• skip

  public long skip(long n)
            throws IOException

  Overrides:

  skip in class InputStream

  Throws:

  IOException

• available

  public int available()
                throws IOException

  Overrides:

  available in class InputStream

  Throws:

  IOException

• seek

  public void seek(long pos)
            throws IOException

  Specified by:

  seek in interface org.apache.hadoop.fs.Seekable

  Throws:

  IOException

• getPos

  public long getPos()
              throws IOException

  Specified by:

  getPos in interface org.apache.hadoop.fs.Seekable

  Throws:

  IOException

• seekToNewSource

  public boolean seekToNewSource(long targetPos)
                          throws IOException

  Specified by:

  seekToNewSource in interface org.apache.hadoop.fs.Seekable

  Throws:

  IOException

• close

  public void close()
             throws IOException

  Specified by:

  close in interface Closeable

  Specified by:

  close in interface AutoCloseable

  Overrides:

  close in class InputStream

  Throws:

  IOException

• mark

  public void mark(int readlimit)

  Overrides:

  mark in class InputStream

• reset

  public void reset()
             throws IOException

  Overrides:

  reset in class InputStream

  Throws:

  IOException

• markSupported

  public boolean markSupported()

  Overrides:

  markSupported in class InputStream

• tryOpen

  private org.apache.hadoop.fs.FSDataInputStream tryOpen()
                                                  throws IOException

  Try to open the file from one of the available locations.

  Returns:

  FSDataInputStream stream of the opened file link

  Throws:

  IOException - on unexpected error, or file not found.