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

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

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

2020年8月25日79评论

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

2020年8月18日88评论

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

2020年8月17日73评论

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

2020年8月14日73评论

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

2020年8月5日72评论

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

2020年8月3日105评论

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

2020年7月23日107评论

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

2020年5月29日139评论

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

2020年4月10日132评论

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

2020年4月5日84评论