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)

Reply via email to