You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "MOBIN (Jira)" <ji...@apache.org> on 2022/09/09 19:18:00 UTC

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

MOBIN created FLINK-29252:
-----------------------------

             Summary: 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


Support create table-store table with 'connector'='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}



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