cascading.tuple
Class TupleInputStream

java.lang.Object
  java.io.InputStream
      java.io.FilterInputStream
          java.io.DataInputStream
              cascading.tuple.TupleInputStream

All Implemented Interfaces:

Closeable, DataInput

public class TupleInputStream
extends DataInputStream

Class TupleInputStream is used internally to read Tuples from storage.

Nested Class Summary

static interface

TupleInputStream.ElementReader

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

TupleInputStream(InputStream inputStream)

TupleInputStream(InputStream inputStream, TupleInputStream.ElementReader elementReader)

Method Summary

void	close()
IndexTuple	readIndexTuple()
IndexTuple	readIndexTuple(IndexTuple indexTuple)
Tuple	readTuple()
Tuple	readTuple(Tuple tuple)
TuplePair	readTuplePair()
TuplePair	readTuplePair(TuplePair tuplePair)

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, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

TupleInputStream

public TupleInputStream(InputStream inputStream,
                        TupleInputStream.ElementReader elementReader)

TupleInputStream

public TupleInputStream(InputStream inputStream)

Method Detail

readTuple

public Tuple readTuple()
                throws IOException

Throws:

IOException

readTuple

public Tuple readTuple(Tuple tuple)
                throws IOException

Throws:

IOException

readTuplePair

public TuplePair readTuplePair()
                        throws IOException

Throws:

IOException

readTuplePair

public TuplePair readTuplePair(TuplePair tuplePair)
                        throws IOException

Throws:

IOException

readIndexTuple

public IndexTuple readIndexTuple()
                          throws IOException

Throws:

IOException

readIndexTuple

public IndexTuple readIndexTuple(IndexTuple indexTuple)
                          throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Overrides:

close in class FilterInputStream

Throws:

IOException