This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 6cfaac5 Merge pull request #6285: [BEAM-4861] Autocreate directories
when doing an HDFS rename
add 6863ccb Endpoint host port configuration reset issue
add 5dfe848 Endpoint host port configuration reset issue
add be2daa9 Fixes https://issues.apache.org/jira/browse/BEAM-3446.
BaseReadFn to abstract general jedis operations. Separated key fetch using
prefix and get by key into serparate DoFn.
add 88cc752 package private and typo fix
add a498446 Using mget with configurable batch size to increase
efficiency of read ops
add 4249bea fixing equality of batch size
add 728776f fixing order of test arguments, to fix
:beam-sdks-java-io-redis:compileTestJava
add eb1e084 Aggregating on per window, applyiong redis get on per window
batch and sequentially pushing to output collector
add b7c2975 Merge pull request #5841: [BEAM-3446] Fixes RedisIO
non-prefix read operations
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 129 +++++++++++++++++----
.../org/apache/beam/sdk/io/redis/RedisIOTest.java | 33 ++++++
2 files changed, 140 insertions(+), 22 deletions(-)
