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)
