This is an automated email from the ASF dual-hosted git repository.
apilloud pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 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
new 9de4bd9 Merge pull request #15915: [beam-12737] add API to handle
failed rows in the collection due to sql query runtime error
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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 ++--
7 files changed, 314 insertions(+), 55 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%)
