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 f207ad1 (commit)
to 31988c8 (commit)
from f207ad1 [BEAM-12074] Define docstrings for all Series and
StringMethods operations (#14863)
add a7b74b0 [BEAM-12276] Narrow check for output timestamp of event time
timers
add 4cc279c Merge pull request #14718: [BEAM-12276] Narrow check for
output timestamp of event time timers
add 4f1f1c1 [BEAM-12093] Overhaul ElasticsearchIO.Write (#14347)
add 847efa5 [BEAM-9487] Add trigger safety check to GroupByKey
add 99aa83d Merge pull request #14857 from [BEAM-9487] Add trigger safety
check to GroupByKey
add 85b85a5 [BEAM-12370] Support side input in Samza portable runner
(#14883)
add eafa48d [BEAM-12158][BEAM-12341] Pubsub fixes. (#14896)
add 1fd191d Populate use_sdf_read in ExpansionService.
add 31988c8 Merge pull request #14898 from boyuanzz/fix
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
.../apache/beam/runners/core/SimpleDoFnRunner.java | 6 +-
.../streaming/ExecutableStageDoFnOperator.java | 4 +-
.../StreamingSideInputHandlerFactory.java} | 14 +-
runners/samza/build.gradle | 1 +
runners/samza/job-server/build.gradle | 3 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 16 +-
.../runners/samza/runtime/SamzaDoFnRunners.java | 17 +-
.../samza/runtime/SamzaStateRequestHandlers.java | 69 ++
.../samza/translation/GroupByKeyTranslator.java | 65 +-
.../translation/ParDoBoundMultiTranslator.java | 132 +-
.../translation/PortableTranslationContext.java | 13 +-
.../translation/SamzaPublishViewTranslator.java | 39 +-
.../samza/util/SamzaPipelineTranslatorUtils.java | 36 -
sdks/go/pkg/beam/core/runtime/xlangx/resolve.go | 2 +-
sdks/go/pkg/beam/io/pubsubio/pubsubio.go | 20 +-
sdks/go/pkg/beam/io/pubsubio/v1/gen.go | 21 -
sdks/go/pkg/beam/io/pubsubio/v1/v1.pb.go | 278 -----
sdks/go/pkg/beam/io/pubsubio/v1/v1.proto | 41 -
.../beam/runners/dataflow/dataflowlib/translate.go | 35 -
.../org/apache/beam/sdk/transforms/ParDoTest.java | 76 ++
.../sdk/expansion/service/ExpansionService.java | 3 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 26 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 23 +
.../elasticsearch-tests-5/build.gradle | 2 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 32 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 31 +
.../elasticsearch-tests-6/build.gradle | 2 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 32 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 31 +
.../elasticsearch-tests-7/build.gradle | 2 +
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 32 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 31 +
.../elasticsearch/ElasticsearchIOTestCommon.java | 320 ++++-
.../io/elasticsearch/ElasticsearchIOTestUtils.java | 171 ++-
sdks/java/io/elasticsearch/OWNERS | 1 +
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 1277 +++++++++++++++-----
.../examples/complete/game/leader_board_it_test.py | 1 +
.../examples/complete/game/leader_board_test.py | 4 +-
.../apache_beam/examples/snippets/snippets_test.py | 8 +-
.../apache_beam/io/gcp/bigquery_file_loads_test.py | 5 +-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 3 +-
.../python/apache_beam/options/pipeline_options.py | 9 +
sdks/python/apache_beam/pipeline.py | 5 +
.../python/apache_beam/testing/test_stream_test.py | 2 +
.../transforms/combinefn_lifecycle_test.py | 6 +-
sdks/python/apache_beam/transforms/core.py | 17 +-
.../apache_beam/transforms/ptransform_test.py | 30 +
sdks/python/apache_beam/transforms/trigger.py | 112 ++
sdks/python/apache_beam/transforms/trigger_test.py | 128 +-
50 files changed, 2394 insertions(+), 842 deletions(-)
rename
runners/{flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStreamingSideInputHandlerFactory.java
=>
java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/translation/StreamingSideInputHandlerFactory.java}
(93%)
create mode 100644
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStateRequestHandlers.java
delete mode 100644 sdks/go/pkg/beam/io/pubsubio/v1/gen.go
delete mode 100644 sdks/go/pkg/beam/io/pubsubio/v1/v1.pb.go
delete mode 100644 sdks/go/pkg/beam/io/pubsubio/v1/v1.proto
