[beam] branch master updated (5dd484ea234 -> 3d0bc5bdfda)

[yh...@apache.org]

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

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


    from 5dd484ea234 Add Java IO Direct jobs: JDBC, Jms, Snowflake (#28021)
     add 3d0bc5bdfda Remove fastjson library (#28007)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |  1 +
 playground/backend/containers/java/Dockerfile      |  4 --
 sdks/java/extensions/sql/build.gradle              |  1 -
 sdks/java/extensions/sql/datacatalog/build.gradle  |  2 +-
 .../provider/datacatalog/BigQueryTableFactory.java |  5 +-
 .../meta/provider/datacatalog/GcsTableFactory.java |  4 +-
 .../provider/datacatalog/PubsubTableFactory.java   |  4 +-
 sdks/java/extensions/sql/hcatalog/build.gradle     |  1 -
 .../meta/provider/hcatalog/DatabaseProvider.java   |  2 -
 .../apache/beam/sdk/extensions/sql/TableUtils.java | 69 ++++++++++++++++++++++
 .../sql/impl/parser/SqlCreateExternalTable.java    |  7 +--
 .../apache/beam/sdk/extensions/sql/meta/Table.java |  9 +--
 .../provider/SchemaIOTableProviderWrapper.java     |  7 +--
 .../sql/meta/provider/bigquery/BigQueryTable.java  |  8 +--
 .../provider/bigquery/BigQueryTableProvider.java   |  8 +--
 .../sql/meta/provider/bigtable/BigtableTable.java  |  8 +--
 .../meta/provider/kafka/KafkaTableProvider.java    | 23 ++++----
 .../pubsublite/PubsubLiteTableProvider.java        | 18 +++---
 .../provider/seqgen/GenerateSequenceTable.java     |  4 +-
 .../sql/meta/provider/test/TestTableProvider.java  |  4 +-
 .../sql/meta/provider/text/TextTableProvider.java  | 11 ++--
 .../extensions/sql/impl/parser/BeamDDLTest.java    | 23 ++++----
 .../rule/BeamAggregateProjectMergeRuleTest.java    |  5 +-
 .../sql/impl/rule/IOPushDownRuleTest.java          |  5 +-
 .../provider/SchemaIOTableProviderWrapperTest.java |  4 +-
 .../meta/provider/bigquery/BigQueryFilterTest.java |  5 +-
 .../bigquery/BigQueryTableProviderTest.java        | 14 ++---
 .../bigquery/BigQueryTestTableProvider.java        |  4 +-
 .../meta/provider/bigtable/BigtableFilterTest.java |  5 +-
 .../provider/bigtable/BigtableTableFlatTest.java   |  8 +--
 .../provider/kafka/BeamKafkaTableAvroTest.java     |  4 +-
 .../provider/kafka/BeamKafkaTableJsonTest.java     |  4 +-
 .../provider/kafka/BeamKafkaTableProtoTest.java    |  4 +-
 .../provider/kafka/BeamKafkaTableThriftTest.java   |  4 +-
 .../meta/provider/kafka/KafkaTableProviderIT.java  |  4 +-
 .../provider/kafka/KafkaTableProviderTest.java     | 19 +++---
 .../meta/provider/mongodb/MongoDbFilterTest.java   |  5 +-
 .../provider/pubsub/PubsubTableProviderTest.java   |  4 +-
 .../pubsublite/PubsubLiteTableProviderTest.java    |  4 +-
 .../meta/provider/test/TestTableProviderTest.java  | 11 +++-
 ...tTableProviderWithFilterAndProjectPushDown.java |  5 +-
 .../test/TestTableProviderWithFilterPushDown.java  |  5 +-
 .../test/TestTableProviderWithProjectPushDown.java |  5 +-
 .../sql/meta/store/InMemoryMetaStoreTest.java      |  4 +-
 sdks/java/extensions/sql/zetasql/build.gradle      |  2 +-
 .../sql/zetasql/ZetaSQLPushDownTest.java           |  5 +-
 sdks/java/testing/tpcds/build.gradle               |  2 +-
 .../apache/beam/sdk/tpcds/BeamSqlEnvRunner.java    |  5 +-
 48 files changed, 225 insertions(+), 144 deletions(-)
 create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/TableUtils.java