[jira] [Created] (FLINK-17606) Introduce DataGen connector in table

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-17606) Introduce DataGen connector in table

Shang Yuanchun (Jira)
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)