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