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 <[email protected]> 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(-)
