[beam] branch master updated (7e9908a -> 646f596)

[ke...@apache.org]

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

kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 7e9908a  Merge pull request #10726 from kamilwu/fix-gbk-load-test-nr3-params
     add 746636b  Clarify exceptions in SQL modules
     add 646f596  Merge pull request #10699: [BEAM-9203] Clarify exceptions in SQL modules

No new revisions were added by this update.

Summary of changes:
 .../datacatalog/DataCatalogTableProvider.java      |  7 ++-
 .../sql/impl/SqlConversionException.java           |  4 ++
 .../sql/impl/rel/BeamAggregationRel.java           |  2 +-
 .../sdk/extensions/sql/impl/rel/BeamCalcRel.java   |  9 +--
 .../sql/impl/rel/BeamEnumerableConverter.java      |  4 +-
 .../sql/impl/rule/BeamIOPushDownRule.java          |  2 +-
 .../sql/impl/schema/BeamPCollectionTable.java      |  2 +-
 .../transform/agg/AggregationCombineFnAdapter.java |  4 +-
 .../sdk/extensions/sql/meta/BaseBeamTable.java     | 15 +++--
 ...ackage-info.java => InvalidTableException.java} | 17 +++++-
 .../provider/bigquery/BeamBigQuerySqlDialect.java  | 11 ++--
 .../sql/meta/provider/bigquery/BigQueryFilter.java |  4 +-
 .../sql/meta/provider/bigquery/BigQueryTable.java  | 19 +++----
 .../meta/provider/datastore/DataStoreV1Table.java  | 28 +++++++---
 .../sql/meta/provider/kafka/BeamKafkaTable.java    |  3 +-
 .../sql/meta/provider/mongodb/MongoDbTable.java    | 13 +++--
 .../provider/pubsub/PubsubJsonTableProvider.java   |  5 +-
 .../sql/meta/provider/test/TestTableFilter.java    |  4 +-
 .../sql/meta/provider/test/TestTableProvider.java  | 15 ++---
 .../sql/meta/provider/text/TextTableProvider.java  | 15 ++---
 .../extensions/sql/BeamSqlDslAggregationTest.java  |  2 +-
 .../sql/meta/CustomTableResolverTest.java          |  6 +-
 .../sdk/extensions/sql/zetasql/DateTimeUtils.java  |  2 +-
 .../sdk/extensions/sql/zetasql/SqlAnalyzer.java    |  3 +-
 .../SqlExtractTimestampOperatorRewriter.java       |  8 +--
 .../extensions/sql/zetasql/StringFunctions.java    |  2 +-
 .../beam/sdk/extensions/sql/zetasql/TypeUtils.java |  4 +-
 .../sql/zetasql/ZetaSQLCastFunctionImpl.java       |  5 +-
 .../sdk/extensions/sql/zetasql/ZetaSqlUtils.java   |  6 +-
 .../translation/AggregateScanConverter.java        | 10 ++--
 .../zetasql/translation/ExpressionConverter.java   | 64 ++++++++++++----------
 .../zetasql/translation/TableScanConverter.java    |  6 +-
 .../sql/zetasql/ZetaSQLDialectSpecTest.java        |  6 +-
 33 files changed, 179 insertions(+), 128 deletions(-)
 copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/{package-info.java => InvalidTableException.java} (68%)