org.apache.accumulo.server.trace
Class TraceFSDataInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by java.io.FilterInputStream
          extended by java.io.DataInputStream
              extended by org.apache.hadoop.fs.FSDataInputStream
                  extended by org.apache.accumulo.server.trace.TraceFSDataInputStream
All Implemented Interfaces:
Closeable, DataInput, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.Seekable

public class TraceFSDataInputStream
extends org.apache.hadoop.fs.FSDataInputStream


Field Summary
 
Fields inherited from class java.io.FilterInputStream
in
 
Constructor Summary
TraceFSDataInputStream(org.apache.hadoop.fs.FSDataInputStream in)
           
 
Method Summary
 int read(long position, byte[] buffer, int offset, int length)
           
 void readFully(long position, byte[] buffer)
           
 void readFully(long position, byte[] buffer, int offset, int length)
           
 void seek(long desired)
           
 boolean seekToNewSource(long targetPos)
           
 
Methods inherited from class org.apache.hadoop.fs.FSDataInputStream
getPos
 
Methods inherited from class java.io.DataInputStream
read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes
 
Methods inherited from class java.io.FilterInputStream
available, close, mark, markSupported, read, reset, skip
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.io.Closeable
close
 

Constructor Detail

TraceFSDataInputStream

public TraceFSDataInputStream(org.apache.hadoop.fs.FSDataInputStream in)
                       throws IOException
Throws:
IOException
Method Detail

seek

public void seek(long desired)
          throws IOException
Specified by:
seek in interface org.apache.hadoop.fs.Seekable
Overrides:
seek in class org.apache.hadoop.fs.FSDataInputStream
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
Overrides:
read in class org.apache.hadoop.fs.FSDataInputStream
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
Overrides:
readFully in class org.apache.hadoop.fs.FSDataInputStream
Throws:
IOException

readFully

public void readFully(long position,
                      byte[] buffer)
               throws IOException
Specified by:
readFully in interface org.apache.hadoop.fs.PositionedReadable
Overrides:
readFully in class org.apache.hadoop.fs.FSDataInputStream
Throws:
IOException

seekToNewSource

public boolean seekToNewSource(long targetPos)
                        throws IOException
Specified by:
seekToNewSource in interface org.apache.hadoop.fs.Seekable
Overrides:
seekToNewSource in class org.apache.hadoop.fs.FSDataInputStream
Throws:
IOException


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.