[ 
https://issues.apache.org/jira/browse/BAHIR-160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

João Boto updated BAHIR-160:
----------------------------
    Fix Version/s: Flink-1.2.0
                       (was: Flink-1.1.0)

> 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
>            Priority: Major
>             Fix For: Flink-1.2.0
>
>
> 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
(v8.20.10#820010)

Reply via email to