apache-beam - 第 6 | 开发者交流平台

如何将Beam SQL窗口查询与KafkaIO集成？

英文: How to integrate Beam SQL windowing query with KafkaIO? 问题 import avro.shaded.com.google.common....

2020年8月25日84评论

英文: Schema-less JSON to Apache Beam "Row" type? 问题有没有办法将任意的无结构模式（schema-less） JSON 字符串转换...

2020年8月18日95评论

英文: Need support for type "MAP" field in CsvToAvro 问题我正在参考以下网址将CSV转换为Avro： https://github...

2020年8月17日83评论

英文: How do I get a dataflow Job ID from within the pipeline or before the pipeline ran? 问题 I'd like ...

2020年8月14日77评论

英文: Property [region] is marked with contradictory annotations + Apache Beam 2.23 问题我正在升级Beam SDK版本...

2020年8月5日76评论

英文: Apache Beam: How to solve "ParDo requires a deterministic key coder in order to use state a...

2020年8月3日110评论

英文: Does ElasticsearchIO for apache-beam java supports Templating and ValueProvider argument? Error ...

2020年7月23日110评论

英文: Apache Beam count of unique elements 问题我有一个Apache Beam作业，从PubSub中摄取数据，然后加载到BigQuery中，我将PubSub消...

2020年5月29日144评论

英文: Local Pubsub Emulator won't work with Dataflow 问题 private interface Options extends Pipeline...

2020年4月10日137评论

英文: Write to Cloud Storage every X messages from Pubsub 问题以下是翻译好的内容： public static void main(String...

2020年4月5日88评论