遍歷PTABLE在緊縮

Question

我有以下PTables，

PTable<String, String> somePTable1 = somePCollection1.parallelDo(new SomeClass(), 
    Writables.tableOf(Writables.strings(), Writables.strings())); 

PTable<String, Collection<String>> somePTable2 = somePTable1.collectValues(); 

對於somePTable2如上所述，我想創建一個新的文件在somePTable2每個記錄，有沒有什麼辦法來遍歷somePTable2讓我能訪問記錄。我知道我可以將doFn應用於somePTable2，但是可以在DoFn中應用pipeline.write（）操作嗎？

Answer 1

如果你想生成一個記錄你的PTABLE內集合中的每個元素試試這個存儲您的清單，是

somePTable2.values().write() 

，你將需要申請一個DOFN併發出一條記錄在每一個元素收集之前寫它。