英文:
Does Flink have the rate source that Spark has?
问题
在Spark中有一个名为“rate source”的功能，用于进行测试。
因此，您可以执行以下操作：
val df = spark.readStream
.format("rate")
.option("rowsPerSecond", 10)
.load()
它会生成用于测试的无限流记录。Flink是否有类似的功能？
英文:
In Spark there's the rate source, which is used for testing.
So, you do:
val df = spark.readStream
.format("rate")
.option("rowsPerSecond", 10)
.load()
And it produces an unbounded stream of records for testing. Does Flink have anything similar?
答案1
得分: 1
看起来它具有Table API的DataGen连接器：
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/datagen/
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/common/
英文:
Looks like it has the DataGen connector for the Table API:
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/datagen/
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/common/
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论