crunch-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tahir Hameed <tah...@gmail.com>
Subject Apache Crunch Passing a Hash Map to DoFn
Date Wed, 23 Sep 2015 07:56:43 GMT
Hi,

I've a PTable which I store as an Avro file. The PTable file is later to be
used in another DoFn after it is converted into a HashMap.

PTable<String, MyClass> myClassData = table.parallelDo(new
MyClassDoFN(),Avros.tableOf(Avros.strings(),Avros.reflects(MyClass.class)));
Target target=To.avroFile("/user/xyz/output/");
myClassData.write(target,Target.WriteMode.OVERWRITE);

Can you please tell me how this file maybe read in another DoFn?

Best,

Tahir

Mime
View raw message