cascading.tuple.hadoop.io
Class TupleDeserializer

java.lang.Object
  extended by cascading.tuple.hadoop.io.TupleDeserializer
All Implemented Interfaces:
org.apache.hadoop.io.serializer.Deserializer<Tuple>

public class TupleDeserializer
extends Object


Constructor Summary
TupleDeserializer(TupleSerialization.SerializationElementReader elementReader)
           
 
Method Summary
 void close()
           
 Tuple deserialize(Tuple tuple)
           
 void open(InputStream in)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TupleDeserializer

public TupleDeserializer(TupleSerialization.SerializationElementReader elementReader)
Method Detail

deserialize

public Tuple deserialize(Tuple tuple)
                  throws IOException
Throws:
IOException

open

public void open(InputStream in)
Specified by:
open in interface org.apache.hadoop.io.serializer.Deserializer<T>

close

public void close()
           throws IOException
Specified by:
close in interface org.apache.hadoop.io.serializer.Deserializer<T>
Throws:
IOException


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.