[beam] branch nightly-refs/heads/master updated (0daef62a7bd -> a6ea1485b96)

[gi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 0daef62a7bd Merge pull request #17380 from [BEAM-14314][BEAM-9532] Add last_updated field in filesystem.FileMetaData
     add 82e13d52127 [BEAM-13657] Follow up update version warning in __init__ (#17493)
     add 9d834518e94 Merge pull request #17431 from [BEAM-14273] Add integration tests for BQ JSON type for Python BigQueryIO connector
     add f83ced3b8a3 Merge pull request #17205 from [BEAM-14145] [Website] add carousel to homepage
     add 77833b19371 [BEAM-14064] fix es io windowing (#17112)
     add 15770b3fe23 [BEAM-13670] Upgraded ipython from v7 to v8 (#17529)
     add 6a507183642 [BEAM-11104] Enable ProcessContinuation return values, add unit test cases (#17533)
     add 723e898a3cf Revert "Merge pull request #17255 from kileys/test-revert"
     add 4d8e62f1fb2 BEAM-14231: bypass schema cache for test_schema_with_bad_field_raises_helpful_error
     add be7823d0a81 Merge pull request #17525: [BEAM-14231] Roll-forward #17190 with fixes for flake
     add 356dcc81832 [BEAM-14403] Allow Prime to be used with legacy workers.
     add 880b411159f Merge pull request #17536 [BEAM-14403] Allow Prime to be used with legacy workers.
     add 2562b7c84bc fix: JDBC config schema fields order
     add 2314da610c8 Merge pull request #17017: [BEAM-14230] JDBC config schema fields order for python
     add a6ea1485b96 [BEAM-11106] Support drain in Go SDK (#17432)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   2 +
 .../beam/runners/dataflow/DataflowRunner.java      |   6 +-
 sdks/go/pkg/beam/core/funcx/fn.go                  |  18 +-
 sdks/go/pkg/beam/core/funcx/fn_test.go             |  15 +-
 sdks/go/pkg/beam/core/graph/fn.go                  |  58 ++-
 sdks/go/pkg/beam/core/graph/fn_test.go             |  47 +++
 sdks/go/pkg/beam/core/runtime/exec/fn_test.go      |  63 ++-
 sdks/go/pkg/beam/core/runtime/exec/sdf.go          | 115 ++++++
 sdks/go/pkg/beam/core/runtime/exec/sdf_invokers.go |  83 ++++
 .../beam/core/runtime/exec/sdf_invokers_test.go    | 160 +++++++-
 sdks/go/pkg/beam/core/runtime/exec/sdf_test.go     | 104 +++++
 sdks/go/pkg/beam/core/runtime/exec/translate.go    |   9 +-
 sdks/go/pkg/beam/core/runtime/genx/genx.go         |   5 +
 .../pkg/beam/core/runtime/graphx/translate_test.go |   1 +
 sdks/go/pkg/beam/core/sdf/lock.go                  |  12 +
 sdks/go/pkg/beam/core/sdf/sdf.go                   |  12 +
 .../beam/io/rtrackers/offsetrange/offsetrange.go   |   4 +
 .../elasticsearch-tests-5/build.gradle             |   4 -
 .../elasticsearch-tests-6/build.gradle             |   6 +-
 .../elasticsearch-tests-7/build.gradle             |   4 -
 .../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 243 +++++------
 sdks/python/apache_beam/__init__.py                |   2 +-
 sdks/python/apache_beam/coders/row_coder.py        |   9 +
 sdks/python/apache_beam/coders/row_coder_test.py   |  11 +
 sdks/python/apache_beam/io/gcp/bigquery.py         |  17 +
 .../apache_beam/io/gcp/bigquery_json_it_test.py    | 446 +++++++++++++++++++++
 sdks/python/apache_beam/io/jdbc.py                 |   2 +-
 .../runners/interactive/display/display_manager.py |   2 +-
 .../interactive/display/pcoll_visualization.py     |   8 +-
 .../runners/interactive/display/pipeline_graph.py  |   2 +-
 .../runners/interactive/interactive_environment.py |   8 +-
 .../apache_beam/runners/interactive/utils.py       |  14 +-
 .../apache_beam/runners/interactive/utils_test.py  |   8 +-
 sdks/python/apache_beam/typehints/schemas.py       |  12 +-
 sdks/python/apache_beam/typehints/schemas_test.py  |   9 +-
 sdks/python/setup.py                               |   4 +-
 website/www/site/assets/js/keen-slider.min.js      |  15 -
 website/www/site/assets/js/quotes-slider.js        |  42 +-
 website/www/site/assets/js/swiper-bundle.min.js    |  14 +
 website/www/site/assets/scss/_keen-slider.scss     |  40 --
 website/www/site/assets/scss/_quotes.scss          | 207 +++++-----
 website/www/site/data/en/quotes.yaml               |  28 +-
 website/www/site/layouts/index.html                | 370 +++++++++--------
 website/www/site/layouts/partials/head.html        |   2 +-
 .../www/site/layouts/partials/hooks/body-end.html  |   4 +-
 .../site/layouts/partials/quotes/quote-mobile.html |  21 -
 .../www/site/layouts/partials/quotes/quote.html    |  49 ++-
 .../site/static/images/logos/powered-by/blank.jpg  | Bin 0 -> 631 bytes
 .../static/images/logos/powered-by/dataflow.png    | Bin 0 -> 5065 bytes
 49 files changed, 1731 insertions(+), 586 deletions(-)
 create mode 100644 sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py
 delete mode 100644 website/www/site/assets/js/keen-slider.min.js
 create mode 100644 website/www/site/assets/js/swiper-bundle.min.js
 delete mode 100644 website/www/site/assets/scss/_keen-slider.scss
 delete mode 100644 website/www/site/layouts/partials/quotes/quote-mobile.html
 create mode 100644 website/www/site/static/images/logos/powered-by/blank.jpg
 create mode 100644 website/www/site/static/images/logos/powered-by/dataflow.png