[jira] [Commented] (BAHIR-220) Add redis descriptor to make redis connection as a table

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/BAHIR-220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16977300#comment-16977300 ] 

ASF GitHub Bot commented on BAHIR-220:
--------------------------------------

hzyuemeng1 commented on pull request #72: [BAHIR-220] Add redis descriptor to make redis connection as a table
URL: https://github.com/apache/bahir-flink/pull/72
 
 
   currently, for Flink-1.9.0, we can use the catalog to store our stream table source and sink meta.
   for Redis connector, it should exist a Redis table sink so we can register it to catalog, and use Redis as a table in SQL environment
   
   ```
   Redis redis = new Redis()
                   .mode(RedisVadidator.REDIS_CLUSTER)
                   .command(RedisCommand.INCRBY_EX.name())
                   .ttl(100000)
                   .property(RedisVadidator.REDIS_NODES, REDIS_HOST+ ":" + REDIS_PORT);
   tableEnvironment
                   .connect(redis).withSchema(new Schema()
                   .field("k", TypeInformation.of(String.class))
                   .field("v", TypeInformation.of(Long.class)))
                   .registerTableSink("redis");
   tableEnvironment.sqlUpdate("insert into redis select k, v from t1");
   env.execute("Test Redis Table");
   ```
   
 
----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> Add redis descriptor to make redis connection as a table
> --------------------------------------------------------
>
>                 Key: BAHIR-220
>                 URL: https://issues.apache.org/jira/browse/BAHIR-220
>             Project: Bahir
>          Issue Type: Improvement
>          Components: Flink Streaming Connectors
>    Affects Versions: Flink-1.0
>            Reporter: yuemeng
>            Priority: Major
>
> currently, for Flink-1.9.0, we can use the catalog to store our stream table source and sink meta.
> for Redis connector, it should exist a Redis table sink so we can register it to catalog, and use Redis as a table in SQL environment
> {code}
> Redis redis = new Redis()
>                 .mode(RedisVadidator.REDIS_CLUSTER)
>                 .command(RedisCommand.INCRBY_EX.name())
>                 .ttl(100000)
>                 .property(RedisVadidator.REDIS_NODES, REDIS_HOST+ ":" + REDIS_PORT);
> tableEnvironment
>                 .connect(redis).withSchema(new Schema()
>                 .field("k", TypeInformation.of(String.class))
>                 .field("v", TypeInformation.of(Long.class)))
>                 .registerTableSink("redis");
> tableEnvironment.sqlUpdate("insert into redis select k, v from t1");
> env.execute("Test Redis Table");
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)