public abstract class TupleOutputStream extends DataOutputStream
Modifier and Type | Class and Description |
---|---|
static interface |
TupleOutputStream.ElementWriter |
static interface |
TupleOutputStream.TupleElementWriter |
written
out
Constructor and Description |
---|
TupleOutputStream(Map<Class,TupleOutputStream.TupleElementWriter> tupleUnTypedElementWriters,
Map<Class,TupleOutputStream.TupleElementWriter> tupleTypedElementWriters,
OutputStream outputStream,
TupleOutputStream.ElementWriter elementWriter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
TupleOutputStream.TupleElementWriter |
getWriterFor(Class type) |
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) |
void |
writeTyped(Class[] classes,
Tuple tuple) |
void |
writeTypedElement(Class type,
Object element) |
void |
writeUnTyped(Tuple tuple) |
void |
writeWith(TupleOutputStream.TupleElementWriter[] writers,
Tuple tuple) |
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> tupleUnTypedElementWriters, Map<Class,TupleOutputStream.TupleElementWriter> tupleTypedElementWriters, OutputStream outputStream, TupleOutputStream.ElementWriter elementWriter)
public final TupleOutputStream.TupleElementWriter getWriterFor(Class type) throws IOException
IOException
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 writeWith(TupleOutputStream.TupleElementWriter[] writers, Tuple tuple) throws IOException
IOException
public void writeTyped(Class[] classes, Tuple tuple) throws IOException
IOException
public void writeUnTyped(Tuple tuple) throws IOException
IOException
public void writeElementArray(Object[] elements) throws IOException
IOException
public final void writeTypedElement(Class type, Object element) 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.