housezhang created BAHIR-257:
--------------------------------
Summary: RedisDescriptorTest add TableFactory sql operate Test
Key: BAHIR-257
URL: https://issues.apache.org/jira/browse/BAHIR-257
Project: Bahir
Issue Type: Test
Components: Flink Streaming Connectors
Affects Versions: Flink-1.0
Reporter: housezhang
Assignee: housezhang
Fix For: Flink-Next
use flink sql to operator redis ,include create redis sql etc like bellow:
tableEnv.executeSql("CREATE TABLE redis (key STRING, number BIGINT) WITH
('connector.type'='redis'," +
"'redis-mode'='cluster', 'key.ttl' =
'70000','command'='INCRBY_EX','cluster-nodes'='" + REDIS_HOST + ":" +
REDIS_PORT + "')");
tableEnv.executeSql("insert into redis select * from t1");
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
