介绍
在Flink中，Datagen是一个用于生成模拟数据的工具，可以用于在Flink集群中测试和调试Flink作业。它可以生成随机的数据流或批数据，以及按照特定规则生成数据流或批数据。

特性
高度可定制性：Datagen可以生成各种类型的数据，例如数字、字符串、日期等，并可以根据用户的需要进行高度定制。
支持流和批处理：Datagen可以生成无限的数据流或有限的批处理数据，并且可以指定数据生成速率和数量。
易于使用：Datagen可以轻松地集成到Flink作业中，并且可以通过命令行或配置文件进行配置。
使用Datagen可以帮助开发人员快速生成模拟数据，以测试和验证Flink作业的正确性和性能。例如，可以使用Datagen生成一个包含大量随机数据的数据流，并将其传输到Flink作业中进行处理和分析，以验证作业的可靠性和性能。

适用场景
测试和验证Flink作业的正确性：Datagen可以生成各种类型的随机数据，并可以按照特定规则生成数据流或批数据，以测试和验证Flink作业的正确性。例如，可以使用Datagen生成包含随机数据的数据流，并将其传输到Flink作业中进行处理和分析，以验证作业的正确性。
测试和验证Flink作业的性能：Datagen可以生成大量的随机数据，并可以指定数据生成速率和数量。可以使用Datagen生成大规模数据集，以测试和验证Flink作业的性能。例如，可以使用Datagen生成包含大量随机数据的数据流，并将其传输到Flink作业中进行处理和分析，以测试作业的性能。
模拟真实数据：Datagen可以根据特定规则生成数据流或批数据。可以使用Datagen生成模拟真实数据集，以测试和验证Flink作业在生产环境中的行为。例如，可以使用Datagen生成模拟用户行为的数据流，并将其传输到Flink作业中进行处理和分析，以测试作业在生产环境中的性能和可靠性。

Flink sql 实现

CREATE TABLE source ( 
  id INT, 
  ts BIGINT, 
  vc INT
) WITH ( 
  'connector' = 'datagen', 
  'rows-per-second'='1', 
  'fields.id.kind'='random', 
  'fields.id.min'='1', 
  'fields.id.max'='10', 
  'fields.ts.kind'='sequence', 
  'fields.ts.start'='1', 
  'fields.ts.end'='1000000', 
  'fields.vc.kind'='random', 
  'fields.vc.min'='1', 
  'fields.vc.max'='100'
);