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)
