public class KeyTupleDeserializer extends java.lang.Object
Constructor and Description |
---|
KeyTupleDeserializer(TupleSerialization.SerializationElementReader elementReader) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected KeyTuple |
createTuple() |
T |
deserialize(T tuple) |
void |
open(java.io.InputStream in) |
protected void |
setReaders(Fields fields) |
public KeyTupleDeserializer(TupleSerialization.SerializationElementReader elementReader)
protected KeyTuple createTuple()
protected void setReaders(Fields fields)
public void open(java.io.InputStream in)
open
in interface Deserializer<T extends Tuple>
public T deserialize(T tuple) throws java.io.IOException
deserialize
in interface Deserializer<T extends Tuple>
java.io.IOException
public void close() throws java.io.IOException
close
in interface Deserializer<T extends Tuple>
java.io.IOException
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.