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

Reply via email to