• W.T
    2019-06-24
    PCollectionList<String> inputs = PCollectionList.of(input1).and(input2).and(input3);这个地方有两个inputs变量,老师是不是笔误了?第一个inputs应该是collections吧

    作者回复: 谢谢指出!确实是typo,已经联系编辑部更正啦。

    
     1
  • cricket1981
    2019-07-17
    自定义输入输出能个代码示例吗?按时间分区以parquet格式写入hdfs,代码要怎么写?
    
    
我们在线,来聊聊吧