alluxio.network.thrift

Class PeekableTransport

java.lang.Object

org.apache.thrift.transport.TTransport

alluxio.network.thrift.PeekableTransport

All Implemented Interfaces:

Closeable, AutoCloseable

public class PeekableTransport
extends org.apache.thrift.transport.TTransport

A transport that one can peek a given number of bytes from the read stream without changing the read position.

Constructor Summary

Constructors

Constructor and Description
PeekableTransport(org.apache.thrift.transport.TTransport baseTransport)

Method Summary

Modifier and Type	Method and Description
void	close()
void	consumeBuffer(int len) Consumes len bytes from the buffer.
void	flush()
org.apache.thrift.transport.TTransport	getBaseTransport()
int	getBufferPosition()
int	getBytesRemainingInBuffer()
boolean	isOpen()
void	open()
int	peek(byte[] buf, int off, int len) Peaks up to len bytes into buffer buf, starting at offset off.
int	read(byte[] buf, int off, int len)
void	write(byte[] buf, int off, int len)

Methods inherited from class org.apache.thrift.transport.TTransport

getBuffer, peek, readAll, write

Methods inherited from class java.lang.Object

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

Constructor Detail

PeekableTransport

public PeekableTransport(org.apache.thrift.transport.TTransport baseTransport)

Parameters:

baseTransport - the base transport to peek

Method Detail

isOpen

public boolean isOpen()

Specified by:

isOpen in class org.apache.thrift.transport.TTransport

open

public void open()
          throws org.apache.thrift.transport.TTransportException

Specified by:

open in class org.apache.thrift.transport.TTransport

Throws:

org.apache.thrift.transport.TTransportException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.thrift.transport.TTransport

read

public int read(byte[] buf,
                int off,
                int len)
         throws org.apache.thrift.transport.TTransportException

Specified by:

read in class org.apache.thrift.transport.TTransport

Throws:

org.apache.thrift.transport.TTransportException

write

public void write(byte[] buf,
                  int off,
                  int len)
           throws org.apache.thrift.transport.TTransportException

Specified by:

write in class org.apache.thrift.transport.TTransport

Throws:

org.apache.thrift.transport.TTransportException

flush

public void flush()
           throws org.apache.thrift.transport.TTransportException

Overrides:

flush in class org.apache.thrift.transport.TTransport

Throws:

org.apache.thrift.transport.TTransportException

peek

public int peek(byte[] buf,
                int off,
                int len)
         throws org.apache.thrift.transport.TTransportException

Peaks up to len bytes into buffer buf, starting at offset off. This method will not change the underlying position of the read stream.

Parameters:

buf - Array to read into

off - Index to start reading at

len - Maximum number of bytes to read

Returns:

The number of bytes actually read

Throws:

org.apache.thrift.transport.TTransportException - if there was an error reading data

getBufferPosition

public int getBufferPosition()

Overrides:

getBufferPosition in class org.apache.thrift.transport.TTransport

Returns:

current buffer position

getBytesRemainingInBuffer

public int getBytesRemainingInBuffer()

Overrides:

getBytesRemainingInBuffer in class org.apache.thrift.transport.TTransport

Returns:

the number of bytes left in buffer

consumeBuffer

public void consumeBuffer(int len)

Consumes len bytes from the buffer.

Overrides:

consumeBuffer in class org.apache.thrift.transport.TTransport

Parameters:

len - number of bytes to consume

getBaseTransport

public org.apache.thrift.transport.TTransport getBaseTransport()

Returns:

the underlying transport that this wrapper is on