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 96610c9 (commit)
to 2339ffc (commit)
from 96610c9 [BEAM-9547] Add basic support for `DataFrame.{eval,query}`
(#13264)
add 45ce942 [BEAM-11188] Add wrappers to Go Xlang examples, and adjust
front-end. (#13255)
add a7a2e01 Refactor checkpointing configuration code
add 74663e2 [BEAM-9855] Provide an option to configure the Flink state
backend
add d492371 Merge pull request #13116: [BEAM-9855] Provide an option to
configure the Flink state backend
add 8a063ff [BEAM-9980] Don't hardcode Python version in loadtests and
make it switchable. (#13242)
add 2c310d2 [BEAM-8451] annotate python only sections (#11706)
add 640d21f BEAM-11194: Add timer family id support in KeyedTimerData
add 4a62f2b [BEAM-11194] Add timer family id support in SamzaRunner
KeyedTimerData
add 50bd126 [BEAM-9804] Allow user configuration of BigQuery temporary
dataset
add 7038af2 Merge pull request #12960 from [BEAM-9804] Allow user
configuration of BigQuery temporary dataset
add c587216 [BEAM-9547] stubs for non-implemented IO.
add 9f1e2ef Allow not/won't imlement helpers to be used for functions as
well as methods.
add 7461918 Merge pull request #13278 [BEAM-9547] stubs for
non-implemented IO.
add 80952c5 [BEAM-9855] Fix merge conflict between #13116 and #13240.
add 2339ffc Merge pull request #13297: [BEAM-9855] Fix merge conflict
between #13116 and #13240.
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/CommonTestProperties.groovy | 7 -
.test-infra/jenkins/LoadTestConfig.groovy | 5 +-
.test-infra/jenkins/LoadTestsBuilder.groovy | 8 +-
.../jenkins/PythonTestProperties.groovy | 5 +-
.../job_LoadTests_Combine_Flink_Python.groovy | 13 +-
.../jenkins/job_LoadTests_Combine_Python.groovy | 2 +-
.../jenkins/job_LoadTests_GBK_Flink_Python.groovy | 15 +-
.../jenkins/job_LoadTests_GBK_Python.groovy | 2 +-
.../job_LoadTests_GBK_Python_reiterate.groovy | 2 +-
.../job_LoadTests_ParDo_Flink_Python.groovy | 23 +--
.../jenkins/job_LoadTests_ParDo_Python.groovy | 2 +-
.../jenkins/job_LoadTests_Python_Smoke.groovy | 2 +-
.../jenkins/job_LoadTests_SideInput_Python.groovy | 2 +-
.../job_LoadTests_coGBK_Flink_Python.groovy | 11 +-
.../jenkins/job_LoadTests_coGBK_Python.groovy | 2 +-
.../job_PerformanceTests_BigQueryIO_Python.groovy | 2 +-
.../job_PerformanceTests_PubsubIO_Python.groovy | 2 +-
runners/flink/flink_runner.gradle | 2 +
.../runners/flink/FlinkExecutionEnvironments.java | 66 +++++++--
.../beam/runners/flink/FlinkPipelineOptions.java | 16 +++
.../flink/FlinkExecutionEnvironmentsTest.java | 60 ++++++++
.../runners/flink/FlinkPipelineOptionsTest.java | 2 +
.../beam/runners/samza/runtime/KeyedTimerData.java | 8 +-
.../runners/samza/runtime/KeyedTimerDataTest.java | 7 +-
sdks/go/examples/xlang/cogroup_by/cogroup_by.go | 8 +-
sdks/go/examples/xlang/combine/combine.go | 6 +-
.../xlang/combine_globally/combine_globally.go | 6 +-
sdks/go/examples/xlang/flatten/flatten.go | 7 +-
sdks/go/examples/xlang/group_by/group_by.go | 10 +-
sdks/go/examples/xlang/multi_input_output/multi.go | 12 +-
sdks/go/examples/xlang/partition/partition.go | 12 +-
sdks/go/examples/xlang/transforms.go | 85 ++++++++++++
sdks/go/examples/xlang/wordcount/wordcount.go | 6 +-
sdks/go/pkg/beam/core/graph/xlang.go | 12 +-
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 4 +-
sdks/go/pkg/beam/core/runtime/xlangx/expand.go | 28 +++-
sdks/go/pkg/beam/core/runtime/xlangx/translate.go | 10 +-
sdks/go/pkg/beam/xlang.go | 154 +++++----------------
sdks/python/apache_beam/dataframe/frame_base.py | 4 +-
sdks/python/apache_beam/dataframe/io.py | 4 +
sdks/python/apache_beam/io/gcp/bigquery.py | 18 ++-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 45 ++++++
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 23 +--
.../content/en/documentation/runners/direct.md | 36 +++--
.../shortcodes/flink_java_pipeline_options.html | 10 ++
.../shortcodes/flink_python_pipeline_options.html | 10 ++
46 files changed, 501 insertions(+), 275 deletions(-)
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udaf/package-info.java
=> .test-infra/jenkins/PythonTestProperties.groovy (90%)
create mode 100644 sdks/go/examples/xlang/transforms.go
