在Spark中有速率源，用于测试。所以，你做：
val df = spark.readStream .format("rate") .option("rowsPerSecond", 10) .load()
字符串它会产生一个无限的记录流用于测试。Flink有类似的东西吗？
ruarlubt1#
看起来它具有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/的
1条答案
按热度按时间ruarlubt1#
看起来它具有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/的