Jingsong Lee created FLINK-17606:
------------------------------------
Summary: Introduce DataGen connector in table
Key: FLINK-17606
URL:
https://issues.apache.org/jira/browse/FLINK-17606 Project: Flink
Issue Type: Sub-task
Reporter: Jingsong Lee
Assignee: Jingsong Lee
Fix For: 1.11.0
{code:java}
CREATE TABLE user (
id BIGINT,
age INT,
description STRING
) WITH (
'connector.type' = 'datagen',
'connector.rows-per-second'='100',
'connector.total-records'='1000000',
'schema.id.generator' = 'sequence',
'schema.id.generator.start' = '1',
'schema.age.generator' = 'random',
'schema.age.generator.min' = '0',
'schema.age.generator.max' = '100',
'schema.description.generator' = 'random',
'schema.description.generator.length' = '100'
)
-- Default is random generator.
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)