David Maier created BAHIR-160:
---------------------------------
Summary: Allow 'low level' Redis commands for the Redis Flink
Connector
Key: BAHIR-160
URL: https://issues.apache.org/jira/browse/BAHIR-160
Project: Bahir
Issue Type: Improvement
Components: Flink Streaming Connectors
Affects Versions: Flink-1.0
Reporter: David Maier
Fix For: Flink-Next
Hello,
would it be possible to allow the usage of more than the currently wrapped
commands in the flink connector?
Background is that Redis is now supporting modules. Each module can have a
specific set of own commands.
The connector seems to rely on Jedis. Jedis is allowing to execute any kind of
command by providing the 'sendCommand(...)' method as part of the BinaryClient
class. Here an example:
{code:java}
jedis.getClient().sendCommand(...){code}
Further details can be found here:
[https://github.com/xetorthio/jedis/blob/master/src/main/java/redis/clients/jedis/BinaryClient.java]
.
It seems that the class RedisContainer
([https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java])
implements only a portion of the possible Redis commands. So it would be
actually great to have 'sendCommand' as one of the wrapped methods in order to
leverage specific Module functionality on the server side.
I didn't dig too deep into the command mapping part yet, but do you think this
is a feasible?
Regards,
David Maier
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
