public class FramingTupleDeserializer<K,V> extends Object implements Deserializer<Tuple<K,V>,InputStream>
Constructor and Description |
---|
FramingTupleDeserializer(Deserializer<K,InputStream> keyDeserializer,
Deserializer<V,InputStream> valDeserializer) |
public FramingTupleDeserializer(Deserializer<K,InputStream> keyDeserializer, Deserializer<V,InputStream> valDeserializer)
public Iterable<Tuple<K,V>> create(InputStream ins)
Deserializer
create
in interface Deserializer<Tuple<K,V>,InputStream>
Copyright © 2017 The Apache Software Foundation. All rights reserved.