com.groupon.lex.metrics.history.xdr.support.reader

Class AbstractInputStreamReader

java.lang.Object

com.groupon.lex.metrics.history.xdr.support.reader.AbstractInputStreamReader

All Implemented Interfaces:

FileReader, Closeable, AutoCloseable

Direct Known Subclasses:

GzipReader, LzoReader, SnappyReader

public class AbstractInputStreamReader
extends Object
implements FileReader

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractInputStreamReader(InputStream in)
protected	AbstractInputStreamReader(InputStream in, boolean validateAllRead)

Method Summary

Modifier and Type	Method and Description
ByteBuffer	allocateByteBuffer(int size) Allocates a byte buffer.
void	close()
protected static InputStream	newAdapter(FileReader in)
int	read(ByteBuffer data)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractInputStreamReader

protected AbstractInputStreamReader(InputStream in,
                                    boolean validateAllRead)
                             throws IOException

Throws:

IOException

AbstractInputStreamReader

protected AbstractInputStreamReader(InputStream in)
                             throws IOException

Throws:

IOException

Method Detail

read

public int read(ByteBuffer data)
         throws IOException

Specified by:

read in interface FileReader

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

allocateByteBuffer

public ByteBuffer allocateByteBuffer(int size)

Description copied from interface: FileReader

Allocates a byte buffer. The allocated byte buffer will be direct if that is the best format for the writer. The allocated byte buffer will be array-based if that is the best format for the writer.

Specified by:

allocateByteBuffer in interface FileReader

Parameters:

size - The size of the buffer.

Returns:

An allocated buffer of the requested size.

newAdapter

protected static InputStream newAdapter(FileReader in)