public abstract class TupleOutputStream extends DataOutputStream
Modifier and Type | Class and Description |
---|---|
static interface |
TupleOutputStream.ElementWriter |
protected static interface |
TupleOutputStream.TupleElementWriter |
written
out
Constructor and Description |
---|
TupleOutputStream(Map<Class,TupleOutputStream.TupleElementWriter> tupleElementWriters,
OutputStream outputStream,
TupleOutputStream.ElementWriter elementWriter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
writeElement(Object element) |
void |
writeElementArray(Object[] elements) |
abstract void |
writeIndexTuple(IndexTuple indexTuple) |
protected abstract void |
writeIntInternal(int value) |
void |
writeTuple(Tuple tuple) |
void |
writeTuplePair(TuplePair tuplePair) |
flush, size, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF
write
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
write
public TupleOutputStream(Map<Class,TupleOutputStream.TupleElementWriter> tupleElementWriters, OutputStream outputStream, TupleOutputStream.ElementWriter elementWriter)
public void writeTuple(Tuple tuple) throws IOException
IOException
public void writeTuplePair(TuplePair tuplePair) throws IOException
IOException
public abstract void writeIndexTuple(IndexTuple indexTuple) throws IOException
IOException
public void writeElementArray(Object[] elements) throws IOException
IOException
public final void writeElement(Object element) throws IOException
IOException
protected abstract void writeIntInternal(int value) throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class FilterOutputStream
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.