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 91818e5 [BEAM-9482] Disable Kafka perf tests. #15459
add e057430 [BEAM-12802] Define a prefetchable iterator and iterable and
utility functions that work over them.
add 762a619 [BEAM-12802] Define a prefetchable iterator and iterable and
utility functions that work over them.
No new revisions were added by this update.
Summary of changes:
...package-info.java => PrefetchableIterable.java} | 9 +-
.../beam/sdk/fn/stream/PrefetchableIterables.java | 152 ++++++++++++++
...ancingPhaser.java => PrefetchableIterator.java} | 27 +--
.../beam/sdk/fn/stream/PrefetchableIterators.java | 209 ++++++++++++++++++
.../sdk/fn/stream/PrefetchableIterablesTest.java | 138 ++++++++++++
.../sdk/fn/stream/PrefetchableIteratorsTest.java | 233 +++++++++++++++++++++
6 files changed, 753 insertions(+), 15 deletions(-)
copy
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/{package-info.java
=> PrefetchableIterable.java} (81%)
create mode 100644
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterables.java
copy
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/{AdvancingPhaser.java
=> PrefetchableIterator.java} (62%)
create mode 100644
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterators.java
create mode 100644
sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/stream/PrefetchableIterablesTest.java
create mode 100644
sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/stream/PrefetchableIteratorsTest.java
