You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@bahir.apache.org by "Xiaochuan Yu (Jira)" <ji...@apache.org> on 2019/10/14 23:59:00 UTC

[jira] [Created] (BAHIR-219) Flink SQL Redis Sink

Xiaochuan Yu created BAHIR-219:
----------------------------------

             Summary: Flink SQL Redis Sink
                 Key: BAHIR-219
                 URL: https://issues.apache.org/jira/browse/BAHIR-219
             Project: Bahir
          Issue Type: Wish
          Components: Flink Streaming Connectors
            Reporter: Xiaochuan Yu


Moved from  https://issues.apache.org/jira/browse/FLINK-14201 which was a request for a Redis TableSink.

Suggestion from [~jark] :
{quote}I would suggest to take {{Elasticsearch6UpsertTableSink}} as an example, 1) something similar to {{SerializationSchema}} to serialize Row into String. 2) {{set()}} or {{zrem()}} depends on the changeflag of input.
{quote}
 



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