public class HadoopTupleOutputStream extends TupleOutputStream
TupleOutputStream.ElementWriter, TupleOutputStream.TupleElementWriter
Modifier and Type | Field and Description |
---|---|
static int |
WRITABLE_TOKEN
Field WRITABLE_TOKEN
|
written
out
Constructor and Description |
---|
HadoopTupleOutputStream(OutputStream outputStream,
TupleOutputStream.ElementWriter elementWriter) |
Modifier and Type | Method and Description |
---|---|
static TupleOutputStream.TupleElementWriter[] |
getWritersFor(TupleOutputStream.ElementWriter elementWriter,
Class[] keyClasses) |
void |
writeIndexTuple(IndexTuple indexTuple) |
protected void |
writeIntInternal(int value) |
close, getWriterFor, writeElement, writeElementArray, writeTuple, writeTuplePair, writeTyped, writeTypedElement, writeUnTyped, writeWith
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 static final int WRITABLE_TOKEN
public HadoopTupleOutputStream(OutputStream outputStream, TupleOutputStream.ElementWriter elementWriter)
public static TupleOutputStream.TupleElementWriter[] getWritersFor(TupleOutputStream.ElementWriter elementWriter, Class[] keyClasses)
protected void writeIntInternal(int value) throws IOException
writeIntInternal
in class TupleOutputStream
IOException
public void writeIndexTuple(IndexTuple indexTuple) throws IOException
writeIndexTuple
in class TupleOutputStream
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.