public class TuplePairSerializer extends Object
Constructor and Description |
---|
TuplePairSerializer(TupleSerialization.SerializationElementWriter elementWriter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
open(OutputStream out) |
void |
serialize(TuplePair tuple) |
protected void |
setWriters(Fields fields) |
public TuplePairSerializer(TupleSerialization.SerializationElementWriter elementWriter)
public void serialize(TuplePair tuple) throws IOException
serialize
in interface Serializer<TuplePair>
IOException
protected void setWriters(Fields fields)
public void open(OutputStream out)
open
in interface Serializer<T extends Tuple>
public void close() throws IOException
close
in interface Serializer<T extends Tuple>
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.