public class HadoopTupleOutputStream extends TupleOutputStream
TupleOutputStream.ElementWriter, TupleOutputStream.TupleElementWriter
Modifier and Type | Field and Description |
---|---|
static int |
WRITABLE_TOKEN
Field WRITABLE_TOKEN
|
Constructor and Description |
---|
HadoopTupleOutputStream(java.io.OutputStream outputStream,
TupleOutputStream.ElementWriter elementWriter) |
Modifier and Type | Method and Description |
---|---|
static TupleOutputStream.TupleElementWriter[] |
getWritersFor(TupleOutputStream.ElementWriter elementWriter,
java.lang.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
public static final int WRITABLE_TOKEN
public HadoopTupleOutputStream(java.io.OutputStream outputStream, TupleOutputStream.ElementWriter elementWriter)
public static TupleOutputStream.TupleElementWriter[] getWritersFor(TupleOutputStream.ElementWriter elementWriter, java.lang.Class[] keyClasses)
protected void writeIntInternal(int value) throws java.io.IOException
writeIntInternal
in class TupleOutputStream
java.io.IOException
public void writeIndexTuple(IndexTuple indexTuple) throws java.io.IOException
writeIndexTuple
in class TupleOutputStream
java.io.IOException
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.