You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2021/08/31 16:20:23 UTC

[beam] 01/01: [BEAM-12802] Refactor DataStreamsDecoder so that it becomes aware of the ByteString iterator and in the future will be able to answer whether there is data available or do we need to fetch more data.

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit a328d0e618ae58c9d78051d4aca89949d43e2775
Merge: bd3649e 95fa963
Author: Lukasz Cwik <lu...@gmail.com>
AuthorDate: Tue Aug 31 09:19:19 2021 -0700

    [BEAM-12802] Refactor DataStreamsDecoder so that it becomes aware of the ByteString iterator and in the future will be able to answer whether there is data available or do we need to fetch more data.

 .../org/apache/beam/sdk/fn/stream/DataStreams.java | 160 ++++++++++-----------
 .../apache/beam/sdk/fn/stream/DataStreamsTest.java |  48 ++-----
 .../beam/fn/harness/state/FnApiStateAccessor.java  |   4 +-
 .../beam/fn/harness/state/StateBackedIterable.java |   4 +-
 .../fn/harness/state/StateFetchingIterators.java   |   8 +-
 5 files changed, 98 insertions(+), 126 deletions(-)