[
https://issues.apache.org/jira/browse/BAHIR-85?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878188#comment-16878188
]
ASF subversion and git services commented on BAHIR-85:
------------------------------------------------------
Commit 4f92704328f5e4be4a6493193c132461cf9b2cc3 in bahir-flink's branch
refs/heads/master from Ton van Bart
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=4f92704 ]
[BAHIR-85] Enable changing additional key without restarting (#60)
We have a use case where we want to sink data to Redis as hashes but have the
hashes stored under different keys which are also extracted from the data. This
change makes this possible in a backward-compatible manner.
> Redis Sink Connector should allow update of command without reinstatiation
> ---------------------------------------------------------------------------
>
> Key: BAHIR-85
> URL: https://issues.apache.org/jira/browse/BAHIR-85
> Project: Bahir
> Issue Type: Improvement
> Components: Flink Streaming Connectors
> Reporter: Atharva Inamdar
> Priority: Major
>
> ref: FLINK-5478
> `getCommandDescription()` gets called when RedisSink is instantiated. This
> happens only once and thus doesn't allow the command to be updated during run
> time.
> Use Case:
> As a dev I want to store some data by day. So each key will have some date
> specified. this will change over course of time. for example:
> `counts_for_1484265600000` for 2017-01-13. This is not limited to any
> particular command.
> connector:
> https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java#L114
> I wish `getCommandDescription()` could be called in `invoke()` so that the
> key can be updated without having to restart.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
