[jira] [Closed] (FLINK-29252) Support create table-store table with 'connector'='table-store'

["Jingsong Lee (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jingsong Lee closed FLINK-29252.
--------------------------------
    Fix Version/s: table-store-0.3.0
         Assignee: Jingsong Lee  (was: MOBIN)
       Resolution: Fixed

master: bb411ab9d5ffdf11cc071353e2fbc1e184327085

> Support create table-store table with 'connector'='table-store'
> ---------------------------------------------------------------
>
>                 Key: FLINK-29252
>                 URL: https://issues.apache.org/jira/browse/FLINK-29252
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table Store
>    Affects Versions: table-store-0.3.0
>            Reporter: MOBIN
>            Assignee: Jingsong Lee
>            Priority: Minor
>              Labels: pull-request-available
>             Fix For: table-store-0.3.0
>
>
> Support create table-store table with 'connector'='table-store': 
> sink to table-store:
> {code:java}
> SET 'execution.checkpointing.interval' = '10 s';
> CREATE TEMPORARY TABLE word_table (
>     word STRING
> ) WITH (
>     'connector' = 'datagen',
>     'fields.word.length' = '1'
> );
> CREATE TABLE word_count (
>     word STRING PRIMARY KEY NOT ENFORCED,
>     cnt BIGINT
> ) WITH(
>   'connector' = 'table-store',
>   'catalog-name' = 'test-catalog',
>   'default-database' = 'test-db',  //should rename 'catalog-database'？
>   'catalog-table' = 'test-tb',
>   'warehouse'='file:/tmp/table_store'
> );
> INSERT INTO word_count SELECT word, COUNT(*) FROM word_table GROUP BY word; {code}
> source from table-store:
> {code:java}
> SET 'execution.checkpointing.interval' = '10 s';
> CREATE TABLE word_count (
>     word STRING PRIMARY KEY NOT ENFORCED,
>     cnt BIGINT
> ) WITH(
>   'connector' = 'table-store',
>   'catalog-name' = 'test-catalog',
>   'default-database' = 'test-db',
>   'catalog-table' = 'test-tb',
>   'warehouse'='file:/tmp/table_store'
> );
> CREATE TEMPORARY TABLE word_table (
>     word STRING
> ) WITH (
>     'connector' = 'print'
> );
> INSERT INTO word_table SELECT word FROM word_count;{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)