pegasus.mapreduce.common.io

Class DirectReader

java.lang.Object

pegasus.mapreduce.common.io.DirectReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class DirectReader
extends java.lang.Object
implements java.io.Closeable

Constructor Summary

Constructors

Constructor and Description
DirectReader(java.lang.String path)
DirectReader(java.lang.String path, int bufferSize)

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.String	getPath()
boolean	hasNext()
void	init()
void	mark()
int	readInt()
long	readLong()
void	reset()
void	rewind(int numBytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectReader

public DirectReader(java.lang.String path)
             throws java.io.IOException

Throws:

java.io.IOException

DirectReader

public DirectReader(java.lang.String path,
                    int bufferSize)
             throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getPath

public java.lang.String getPath()

readInt

public int readInt()
            throws java.io.IOException

Throws:

java.io.IOException

readLong

public long readLong()
              throws java.io.IOException

Throws:

java.io.IOException

hasNext

public boolean hasNext()
                throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

mark

public void mark()
          throws java.io.IOException

Throws:

java.io.IOException

reset

public void reset()
           throws java.io.IOException

Throws:

java.io.IOException

init

public void init()
          throws java.io.IOException

Throws:

java.io.IOException

rewind

public void rewind(int numBytes)
            throws java.io.IOException

Throws:

java.io.IOException