public class FramingTupleSerializer<K,V> extends Object implements Serializer<Tuple<K,V>,OutputStream>
Constructor and Description |
---|
FramingTupleSerializer(Serializer<K,OutputStream> keySerializer,
Serializer<V,OutputStream> valSerializer) |
public FramingTupleSerializer(Serializer<K,OutputStream> keySerializer, Serializer<V,OutputStream> valSerializer)
public Accumulable<Tuple<K,V>> create(OutputStream os)
Serializer
create
in interface Serializer<Tuple<K,V>,OutputStream>
Copyright © 2017 The Apache Software Foundation. All rights reserved.