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 a884aae Merge pull request #5533: [BEAM-4421] Fix for issue with
reading s3 files using ParquetIO
add 639db9f [SQL] Replace planner.compilePipeline() with
sqlEnv.parseQuery()
add fd0a2c5 [SQL] Add sqlEnv.executeDdl()
add 5235d36 [SQL] Make planner package-private
add 3f929b0 [SQL] Add factory methods to BeamSqlEnv
add 52cbc18 [SQL] Rename ReadOnlyTableProvider
add 0427b6b [SQL] Wrap SQL parsing exceptions in ParseException
new e33da0d Merge pull request #5530: [SQL] BeamSqlEnv refactor
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:
.../apache/beam/sdk/extensions/sql/BeamSqlCli.java | 19 +---
.../beam/sdk/extensions/sql/QueryTransform.java | 17 +--
.../sql/impl/{planner => }/BeamQueryPlanner.java | 27 +----
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 68 ++++++++++-
.../{package-info.java => ParseException.java} | 14 ++-
.../extensions/sql/impl/parser/SqlCreateTable.java | 2 +-
.../extensions/sql/impl/planner/BeamRuleSets.java | 4 +-
.../extensions/sql/impl/planner/package-info.java | 4 +-
.../meta/provider/InMemoryMetaTableProvider.java | 2 +
...bleProvider.java => ReadOnlyTableProvider.java} | 15 ++-
.../extensions/sql/BeamSqlDslAggregationTest.java | 15 ++-
.../sdk/extensions/sql/BeamSqlDslFilterTest.java | 12 +-
.../sdk/extensions/sql/BeamSqlDslProjectTest.java | 7 +-
.../sdk/extensions/sql/BeamSqlDslUdfUdafTest.java | 9 +-
.../sdk/extensions/sql/impl/JdbcDriverTest.java | 6 +-
.../sql/impl/parser/BeamDDLNestedTypesTest.java | 28 ++---
.../extensions/sql/impl/parser/BeamDDLTest.java | 126 ++++++++++++---------
.../sql/impl/parser/ParserTestUtils.java | 33 ------
.../sql/impl/parser/TestTableProvider.java} | 28 +++--
.../sdk/extensions/sql/impl/rel/BaseRelTest.java | 8 +-
.../extensions/sql/impl/rel/BeamSortRelTest.java | 4 +-
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 26 +----
22 files changed, 254 insertions(+), 220 deletions(-)
rename
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/{planner
=> }/BeamQueryPlanner.java (83%)
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/{package-info.java
=> ParseException.java} (74%)
rename
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/{BeamSqlTableProvider.java
=> ReadOnlyTableProvider.java} (80%)
delete mode 100644
sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/parser/ParserTestUtils.java
copy
sdks/java/extensions/sql/src/{main/java/org/apache/beam/sdk/extensions/sql/meta/provider/InMemoryMetaTableProvider.java
=>
test/java/org/apache/beam/sdk/extensions/sql/impl/parser/TestTableProvider.java}
(60%)
--
To stop receiving notification emails like this one, please contact
[email protected].
