我是GoogleDataFlow的新手,并且遵循了来自这里在Eclipse中构建样本WordCount项目。但是,当我设置“新启动配置”时,没有选择“BlockingDataFlowPipelinerner”的选项,如所示的屏幕截图所示。只有“DirectPipeLinerner”和“DataFlowPipeLinerner”。谁能帮忙?看答案这BlockingDataflowPipelineRunner和DataflowPipelineRunner已合并。您应该能够使用DataflowRunner.现在可以通过调用代码中的阻塞行为可用waituntilfinish在代码中,示例应该做。