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)

Reply via email to