Here's my code
这是我的代码
PCollection<MyProto> pCollection = p.apply(TextIO.Read.from(
"gs://my_bucket/*")
.withCoder(Proto2Coder.of(MyProto.class)));
PCollection<MyProto>
阅读背景：
Google Cloud Dataflow：无法使用TextIO.Read解析proto
来源：互联网
分享到：
