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)