beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ieme...@apache.org
Subject [beam] branch master updated (6cfaac5 -> b7c2975)
Date Wed, 19 Sep 2018 15:14:11 GMT
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(-)


Mime
View raw message