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 fd00fc9 [BEAM-13223] Documents two new features of cross-language
transforms (#15941)
add 496012b [BEAM-13226] Batch metrics parsing errors (#15972)
add a89dec4 [BEAM-13239] pass through io.EOF when decoding row (#15971)
add 63f3338 [BEAM-5378] Register types & funcs for examples. (#15970)
add bfc71b0 [BEAM-3293] Add initial MultiMap side input backing type
(#15975)
add b08b182 Key-inferable type hints for CombinePerKey.
add 70be087 Type inference deterministic coder fix for old Python
versions.
add 4a5aecc Merge pull request #15969 Key-inferable type hints for
CombinePerKey.
add 7f301ae Fully resolve type variables after PTransform type inference.
add 5c4f99b Add comment about wildcard.
add 77b1aeb Merge pull request #15967 Fully resolve type variables after
PTransform type inference.
add 86c8472 [BEAM-13238] Bump all Dataflow Java VR timeouts (#15979)
add 089bce7 Implement type variable binding for union types.
add 080308b Also implement type matching for union types.
add 6b14474 Merge pull request #15949 Implement type variable binding for
union types.
add 7d54488 Merge pull request #15978: [BEAM-8691] Upgrading Java deps
compatible with GCP libs
add 16911c5 [BEAM-13221] Don't drop last data. (#15939)
add e4ed78d [BEAM-12737] error handling for sql calc error
add 75d0654 [BEAM-12737] error handling for sql calc error
add e34312d [BEAM-12737] error handling for sql calc error
add c6c88a4 [BEAM-12737] add test
add bd0d907 [BEAM-12737] fix build
add d5c1941 [BEAM-12737] fix build
add 4943485 Merge branches 'BEAM-12737-failed-calc-rows-transformer' and
'master' of https://github.com/brachi-wernick/beam into
BEAM-12737-failed-calc-rows-transformer
add a1374cb revert
add f544e6f [beam-12737] cr fix
https://github.com/apache/beam/pull/15915#discussion_r745129204
add 3805535 [beam-12737] cr fixes
add 6bf54e2 [beam-12737] send errorTransformer to `buildPTransform`
add 96916b2 [beam-12737] send errorTransformer to `buildPTransform`
add c0abbce [beam-12737] fix type `? extends POutput`
add df8912d [beam-12737] add complex test, change error row type
add 9de4bd9 Merge pull request #15915: [beam-12737] add API to handle
failed rows in the collection due to sql query runtime error
No new revisions were added by this update.
Summary of changes:
...PostCommit_Java_ValidatesRunner_Dataflow.groovy | 2 +-
...mit_Java_ValidatesRunner_Dataflow_Java11.groovy | 2 +-
..._Java_ValidatesRunner_Dataflow_Streaming.groovy | 2 +-
...tCommit_Java_ValidatesRunner_Dataflow_V2.groovy | 2 +-
...va_ValidatesRunner_Dataflow_V2_Streaming.groovy | 2 +-
CHANGES.md | 5 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
.../examples/complete/autocomplete/autocomplete.go | 13 +-
sdks/go/examples/contains/contains.go | 2 +
sdks/go/examples/cookbook/combine/combine.go | 4 +
sdks/go/examples/cookbook/filter/filter.go | 7 +
sdks/go/examples/cookbook/join/join.go | 10 ++
sdks/go/examples/cookbook/max/max.go | 7 +
sdks/go/examples/cookbook/tornadoes/tornadoes.go | 8 +
.../debugging_wordcount/debugging_wordcount.go | 2 +
sdks/go/examples/grades/grades.go | 22 ++-
sdks/go/examples/multiout/multiout.go | 9 +-
sdks/go/examples/pingpong/pingpong.go | 10 +-
sdks/go/examples/wordcount/wordcount.go | 2 +
sdks/go/examples/yatzy/yatzy.go | 2 +
sdks/go/pkg/beam/core/graph/coder/row_decoder.go | 10 +-
sdks/go/pkg/beam/core/runtime/exec/input.go | 46 ++++++
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 11 +-
.../pkg/beam/core/runtime/harness/datamgr_test.go | 18 +++
sdks/go/pkg/beam/core/runtime/harness/logging.go | 2 +-
sdks/go/pkg/beam/core/runtime/metricsx/metricsx.go | 25 +--
sdks/go/test/integration/wordcount/wordcount.go | 5 +
.../beam/sdk/extensions/sql/SqlTransform.java | 15 +-
.../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 82 ++++++++--
.../sdk/extensions/sql/impl/rel/BeamRelNode.java | 9 ++
.../extensions/sql/impl/rel/BeamSqlRelUtils.java | 40 ++++-
.../sdk/extensions/sql/error/BeamSqlErrorTest.java | 167 +++++++++++++++++++++
.../sdk/extensions/sql/error/CalculatePrice.java | 30 ++--
.../beam/sdk/extensions/sql/error/CastUdf.java | 26 ++--
sdks/python/apache_beam/pipeline.py | 14 +-
sdks/python/apache_beam/transforms/core.py | 24 +--
.../apache_beam/transforms/ptransform_test.py | 13 ++
.../apache_beam/typehints/typed_pipeline_test.py | 18 +++
sdks/python/apache_beam/typehints/typehints.py | 24 ++-
.../python/apache_beam/typehints/typehints_test.py | 38 +++++
40 files changed, 631 insertions(+), 107 deletions(-)
create mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/error/BeamSqlErrorTest.java
copy playground/frontend/lib/modules/sdk/models/sdk.dart =>
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/error/CalculatePrice.java
(66%)
copy playground/frontend/lib/modules/sdk/models/sdk.dart =>
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/error/CastUdf.java
(71%)
