[GitHub] [flink-table-store] MOBIN-F opened a new pull request, #290: [FLINK-29252]Support create table-store table with 'connector'='table-store'

Fri, 09 Sep 2022 12:22:33 -0700 


MOBIN-F opened a new pull request, #290:
URL: https://github.com/apache/flink-table-store/pull/290

   [[FLINK-29252]](https://issues.apache.org/jira/browse/FLINK-29252)Support 
create table-store table with 'connector'='table-store'
   sink to table-store: 
   ```
   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; 
   ```
   
   source from table-store: 
   ```
   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;
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to