You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "sam lin (Jira)" <ji...@apache.org> on 2020/03/05 01:27:00 UTC

[jira] [Created] (BAHIR-226) flink-connector-redis RedisMapper supports varargs by returning List type in `getValueFromData` function

sam lin created BAHIR-226:
-----------------------------

             Summary: flink-connector-redis RedisMapper supports varargs by returning List<T> type in `getValueFromData` function
                 Key: BAHIR-226
                 URL: https://issues.apache.org/jira/browse/BAHIR-226
             Project: Bahir
          Issue Type: New Feature
          Components: Flink Streaming Connectors
         Environment: Java8, flink1.10, flink-redis-sink-connector 1.1.5
            Reporter: sam lin


Jedis can support varargs that takes multiple arguments to take the same operations. e.g. [SADD]([https://redis.io/commands/sadd]).  In Jedis code: [https://github.com/xetorthio/jedis/blob/master/src/main/java/redis/clients/jedis/Jedis.java#L1212]

I think whether we could support this feature in sink connector?  This will be very useful in terms of performance and flexiblity.

Didn't dive deep into implementation, but for interface wise, `RedisMapper::getValueFromData()` could return List<T>?  Or a new Mapper.



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