[
https://issues.apache.org/jira/browse/FLINK-29252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-29252:
--------------------------
Description:
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}
was:
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}
> 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
>
> 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)
