This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from bcb56b7 (commit)
to 9e929bd (commit)
from bcb56b7 Merge pull request #14927 from [BEAM-12400] MongoDBIO support
for update within documents
add fed8fac [BEAM-12828] Convert UseTestStream tests to use Long instead
of Integer
add de96d57 Apply SpotlessJava
add 7213747 Apply SpotlessJava
add 559fbc3 Update runners/flink/job-server/flink_job_server.gradle
add 3fe037d [BEAM-12828, BEAM-11310, BEAM-12048, BEAM-12050, BEAM-12822]
Convert UseTestStream tests to use Long instead of Integer
add e0c84e1 [BEAM-3385] Add requires about `equals()` and `hashMethod()`
to SerializableCoder's javadoc
add 14799b3 [BEAM-3385] Changes regarding spotlessApply task
add fd489d8 [BEAM-3385] wrap up equals() and hashCode() methods into links
add 823ab5a [BEAM-3385] SerializableCoder should document types need to
implement equals and hashCode correctly
add 7395188 [BEAM-12838] Update artifact local path for DataflowRunner
Java
add c2315a6 separate into resolveArtifacts method
add 9952e21 add test
add 9bfbd74 update
add a1474fd fix formatting
add 15abcf3 Merge pull request #15454 from ihji/BEAM-12838
add 90c1e48 [BEAM-12850] Calcite drops empty Calc now
add 3bd56de Merge pull request #15466: [BEAM-12850] Calcite drops empty
Calc now
add 15edc40 [BEAM-12852] Revert BigTable changes, just cast to bigint
add ce05e32 Merge pull request #15468: [BEAM-12852] Revert change to int,
use bigint in BigTable test
add a853a11 [BEAM-12853] VALUES produces a UNION, window can't be set
afterwards
add 0fc4ffd Merge pull request #15469: [BEAM-12853] VALUES produces a
UNION, window can't be set afterwards
add 5bf7dcb Disable Kafka perf tests.
add 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.
add e141b48 [BEAM-12851] Map output table names
add 9e929bd Merge pull request #15467: [BEAM-12851] Map output table names
No new revisions were added by this update.
Summary of changes:
.../jenkins/job_PerformanceTests_KafkaIO_IT.groovy | 3 +-
runners/flink/job-server/flink_job_server.gradle | 15 +-
.../beam/runners/dataflow/DataflowRunner.java | 57 +++-
.../beam/runners/dataflow/DataflowRunnerTest.java | 91 ++++++
runners/samza/job-server/build.gradle | 10 +-
.../apache/beam/sdk/coders/SerializableCoder.java | 3 +
.../apache/beam/sdk/testing/TestStreamTest.java | 48 +--
.../beam/sdk/transforms/DeduplicateTest.java | 52 ++--
.../apache/beam/sdk/transforms/DistinctTest.java | 45 +--
.../org/apache/beam/sdk/transforms/ParDoTest.java | 330 ++++++++++-----------
.../org/apache/beam/sdk/transforms/ViewTest.java | 19 +-
.../sdk/extensions/sql/impl/rel/BeamIOSinkRel.java | 6 +-
.../sdk/extensions/sql/PubsubToBigqueryIT.java | 4 +-
.../sql/impl/rel/BeamEnumerableConverterTest.java | 3 +-
.../provider/bigquery/BigQueryReadWriteIT.java | 18 +-
.../provider/bigtable/BigtableTableFlatTest.java | 6 +-
.../meta/provider/bigtable/BigtableTableIT.java | 2 +-
.../provider/bigtable/BigtableTableTestUtils.java | 24 +-
.../bigtable/BigtableTableWithRowsTest.java | 6 +-
.../provider/pubsub/PubsubTableProviderIT.java | 5 +-
...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 +++++++++++++++
.../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 13 +-
27 files changed, 1197 insertions(+), 331 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
