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)