You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/01/20 03:53:55 UTC

[beam] branch nightly-refs/heads/master updated (3759d44 -> f31cad0)

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 3759d44  [BEAM-13665] Make SpannerIO projectID optional again (#16547)
     add 6b5a98f  [BEAM-13015] Add state caching capability to be used as hint for runners to not duplicate cached data if the SDK can do it for user state and side inputs. (#16525)
     add fd3f207  Merge pull request #16309: [BEAM-13503] Set a default value to throwWriteErrors in BulkIO constructor
     add b458f8f  [BEAM-13015] Provide caching statistics in the status client. (#16495)
     add c392a00  [BEAM-13611] Skip test_xlang_jdbc_write (#16554)
     add db769cb  Merge pull request #16370 from [BEAM-13556] playground - color and scroll tabs with new content
     add 4fafa60  Merge pull request #16531 from [BEAM-13567] [playground] Handle run code validation and preparation errors
     add 2148a8e  Merge pull request #16533 from [BEAM-13548] [Playground] Add example description popover
     add 33ae030  Merge pull request #16519 from [BEAM-13639] [Playground] Add notification to Log/Output tabs about cached example
     add 0cbd29f  Merge pull request #16518 from [BEAM-13619] [Playground] Add loading animation to the catalog
     add 8ff406e  Merge pull request #16243 from darshan-sj/feature/support-priority-spannerio - Making rpcPriority a ValueProvider in SpannerConfig
     add d67e266  [BEAM-13683] Make cross-language SQL example pipeline (#16567)
     add ef07638  [BEAM-13688] fixed type in BPG 4.5.3 window section (#16560)
     add a5935c7  Remove obsolete commands from Inventory job. (#16564)
     add 72a8c2c  Disable logging for memoization test. (#16556)
     add 2d1157e  Merge pull request #16472: [BEAM-13697] Add SchemaFieldNumber annotation
     add f31cad0  Merge pull request #16373 from [BEAM-13515] [Playground] Hiding lines in an example that are not necessary

No new revisions were added by this update.

Summary of changes:
 .test-infra/jenkins/job_Inventory.groovy           |   2 -
 .../fn-execution/src/main/proto/beam_fn_api.proto  |   4 +
 .../pipeline/src/main/proto/beam_runner_api.proto  |   6 +
 .../loading_indicator/loading_indicator.dart}      |  20 +-
 playground/frontend/lib/constants/sizes.dart       |   2 +
 .../modules/editor/components/editor_textarea.dart |  59 ++++++
 .../lib/modules/editor/components/run_button.dart  |  58 +++---
 .../code_repository/code_client/code_client.dart   |  10 +
 .../code_client/grpc_code_client.dart              |  26 ++-
 .../code_repository/code_repository.dart           |  20 +-
 .../code_repository/run_code_result.dart           |  10 +-
 .../description_popover/description_popover.dart}  |  46 ++---
 .../description_popover_button.dart                |  80 +++++++
 .../example_list/expansion_panel_item.dart         |  31 ++-
 .../lib/modules/examples/example_selector.dart     |  40 ++--
 .../lib/modules/output/components/output.dart      |  40 +++-
 .../lib/modules/output/components/output_area.dart |  15 +-
 .../components/output_header/output_header.dart    |  13 +-
 .../components/output_header/output_tab.dart       |  80 +++++++
 .../components/output_header/output_tabs.dart      |  43 ++--
 .../modules/output/components/output_result.dart   |  29 ++-
 .../components/editor_textarea_wrapper.dart        |  58 +++---
 .../pages/playground/states/playground_state.dart  |   5 +-
 .../code_repository/code_repository_test.dart      |  80 +++++++
 .../code_repository_test.mocks.dart                |  17 ++
 .../states/example_selector_state_test.mocks.dart  |   7 +
 .../runners/core/construction/Environments.java    |   7 +-
 .../core/construction/EnvironmentsTest.java        |  22 ++
 sdks/go/examples/xlang/sql/sql.go                  | 130 ++++++++++++
 .../apache/beam/sdk/schemas/AutoValueSchema.java   |  54 +++--
 .../sdk/schemas/FieldValueTypeInformation.java     |  25 ++-
 .../apache/beam/sdk/schemas/JavaBeanSchema.java    |  45 +++-
 .../apache/beam/sdk/schemas/JavaFieldSchema.java   |  39 +++-
 ...SchemaFieldName.java => SchemaFieldNumber.java} |  12 +-
 .../apache/beam/sdk/schemas/utils/AvroUtils.java   |  12 +-
 .../org/apache/beam/sdk/util/WeightedValue.java    |  24 +++
 .../beam/sdk/schemas/AutoValueSchemaTest.java      |  47 +++++
 .../beam/sdk/schemas/JavaBeanSchemaTest.java       |   5 +-
 .../beam/sdk/schemas/JavaFieldSchemaTest.java      |  23 ++-
 .../beam/sdk/schemas/utils/TestJavaBeans.java      |  30 +++
 .../apache/beam/sdk/schemas/utils/TestPOJOs.java   |  39 ++++
 .../extensions/protobuf/ProtoMessageSchema.java    |   7 +-
 .../java/org/apache/beam/fn/harness/Cache.java     |   3 +
 .../java/org/apache/beam/fn/harness/Caches.java    | 229 ++++++++++++++-------
 .../java/org/apache/beam/fn/harness/FnHarness.java |   3 +-
 .../beam/fn/harness/status/BeamFnStatusClient.java |  17 +-
 .../org/apache/beam/fn/harness/CachesTest.java     |  81 +++++++-
 .../fn/harness/status/BeamFnStatusClientTest.java  |  21 +-
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |   6 +
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |   6 +
 .../sdk/io/elasticsearch/ElasticsearchIOTest.java  |   6 +
 .../elasticsearch/ElasticsearchIOTestCommon.java   |  19 ++
 .../beam/sdk/io/elasticsearch/ElasticsearchIO.java |   1 +
 .../beam/sdk/io/gcp/spanner/BatchSpannerRead.java  |  35 +++-
 .../beam/sdk/io/gcp/spanner/NaiveSpannerRead.java  |  32 ++-
 .../beam/sdk/io/gcp/spanner/SpannerConfig.java     |  10 +-
 .../apache/beam/sdk/io/gcp/spanner/SpannerIO.java  |  12 +-
 .../beam/sdk/io/gcp/spanner/SpannerIOReadTest.java |   4 +-
 .../sdk/io/gcp/spanner/SpannerIOWriteTest.java     |   4 +-
 .../apache/beam/sdk/io/thrift/ThriftSchema.java    |   2 +-
 sdks/python/apache_beam/dataframe/convert_test.py  |   8 +-
 .../io/external/xlang_jdbcio_it_test.py            |   1 +
 .../content/en/documentation/programming-guide.md  |   2 +-
 63 files changed, 1523 insertions(+), 301 deletions(-)
 copy playground/frontend/lib/{modules/output/components/output.dart => components/loading_indicator/loading_indicator.dart} (70%)
 copy playground/frontend/lib/modules/{sdk/components/sdk_selector_row.dart => examples/components/description_popover/description_popover.dart} (57%)
 create mode 100644 playground/frontend/lib/modules/examples/components/description_popover/description_popover_button.dart
 create mode 100644 playground/frontend/lib/modules/output/components/output_header/output_tab.dart
 create mode 100644 sdks/go/examples/xlang/sql/sql.go
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/{SchemaFieldName.java => SchemaFieldNumber.java} (83%)