Package org.apache.commons.vfs2.provider.hdfs

Class HdfsRandomAccessContent

java.lang.Object

org.apache.commons.vfs2.provider.AbstractRandomAccessContent

org.apache.commons.vfs2.provider.hdfs.HdfsRandomAccessContent

All Implemented Interfaces:

Closeable, DataInput, DataOutput, AutoCloseable, org.apache.commons.vfs2.RandomAccessContent

public class HdfsRandomAccessContent
extends org.apache.commons.vfs2.provider.AbstractRandomAccessContent

Provides random access to content in an HdfsFileObject. Currently this only supports read operations. All write operations throw an UnsupportedOperationException.

Since:

2.1

Constructor Summary

Constructors

Constructor	Description
HdfsRandomAccessContent(org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FileSystem fs)	Create random access content.

Method Summary

Modifier and Type	Method	Description
void	close()
long	getFilePointer()
InputStream	getInputStream()
long	length()
boolean	readBoolean()
byte	readByte()
char	readChar()
double	readDouble()
float	readFloat()
void	readFully(byte[] b)
void	readFully(byte[] b, int off, int len)
int	readInt()
String	readLine()
long	readLong()
short	readShort()
int	readUnsignedByte()
int	readUnsignedShort()
String	readUTF()
void	seek(long pos)
void	setLength(long newLength)
int	skipBytes(int n)

Methods inherited from class org.apache.commons.vfs2.provider.AbstractRandomAccessContent

write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from class java.lang.Object

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

Constructor Details

HdfsRandomAccessContent

public HdfsRandomAccessContent(org.apache.hadoop.fs.Path path,
 org.apache.hadoop.fs.FileSystem fs)
                        throws IOException

Create random access content.

Parameters:

path - A Hadoop Path

fs - A Hadoop FileSystem

Throws:

IOException - when the path cannot be processed.

Method Details

close

public void close()
           throws IOException

Throws:

IOException

See Also:

• RandomAccessContent.close()

getFilePointer

public long getFilePointer()
                    throws IOException

Throws:

IOException

See Also:

• RandomAccessContent.getFilePointer()

getInputStream

public InputStream getInputStream()
                           throws IOException

Throws:

IOException

See Also:

• RandomAccessContent.getInputStream()

length

public long length()
            throws IOException

Throws:

IOException

See Also:

• RandomAccessContent.length()

readBoolean

public boolean readBoolean()
                    throws IOException

Throws:

IOException

See Also:

• DataInput.readBoolean()

readByte

public byte readByte()
              throws IOException

Throws:

IOException

See Also:

• DataInput.readByte()

readChar

public char readChar()
              throws IOException

Throws:

IOException

See Also:

• DataInput.readChar()

readDouble

public double readDouble()
                  throws IOException

Throws:

IOException

See Also:

• DataInput.readDouble()

readFloat

public float readFloat()
                throws IOException

Throws:

IOException

See Also:

• DataInput.readFloat()

readFully

public void readFully(byte[] b)
               throws IOException

Throws:

IOException

See Also:

• DataInput.readFully(byte[])

readFully

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

Throws:

IOException

See Also:

• DataInput.readFully(byte[], int, int)

readInt

public int readInt()
            throws IOException

Throws:

IOException

See Also:

• DataInput.readInt()

readLine

public String readLine()
                throws IOException

Specified by:

readLine in interface DataInput

Overrides:

readLine in class org.apache.commons.vfs2.provider.AbstractRandomAccessContent

Throws:

IOException

See Also:

• DataInput.readLine()

readLong

public long readLong()
              throws IOException

Throws:

IOException

See Also:

• DataInput.readLong()

readShort

public short readShort()
                throws IOException

Throws:

IOException

See Also:

• DataInput.readShort()

readUnsignedByte

public int readUnsignedByte()
                     throws IOException

Throws:

IOException

See Also:

• DataInput.readUnsignedByte()

readUnsignedShort

public int readUnsignedShort()
                      throws IOException

Throws:

IOException

See Also:

• DataInput.readUnsignedShort()

readUTF

public String readUTF()
               throws IOException

Throws:

IOException

See Also:

• DataInput.readUTF()

seek

public void seek(long pos)
          throws IOException

Throws:

IOException

See Also:

• RandomAccessContent.seek(long)

setLength

public void setLength(long newLength)
               throws IOException

Throws:

IOException

See Also:

• RandomAccessContent.setLength(long)

skipBytes

public int skipBytes(int n)
              throws IOException

Throws:

IOException

See Also:

• DataInput.skipBytes(int)