[
https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29252:
-----------------------------------
Labels: pull-request-available (was: )
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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)
