This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from bd3649e Merge pull request #15007 from [BEAM-12428] Implement
TokenCredentialSerializer in AzureModule.java
add 95fa963 [BEAM-12802] Refactor DataStreamsDecoder so that it becomes
aware of the ByteString iterator.
new a328d0e [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.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
