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 3ae2a78 Merge pull request #5676: [BEAM-4291] Propagates artifact
retrieval token in Flink runner and to the Java harness
add d4e96c8 [SQL] Correctly represent pipeline
add ddac04e [SQL] Cleanup table IO functions
add e13cd80 [SQL] Simplify overly verbose names
add c23e640 [SQL] Add each Calcite node to Beam graph once
add 8764042 [SQL] Seperate parse from pipeline construction
new fe37c83 Merge pull request #5673: [BEAM-4575] Cleanly transform graph
from Calcite to Beam SQL
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 | 4 +-
.../beam/sdk/extensions/sql/BeamSqlTable.java | 9 ++-
.../beam/sdk/extensions/sql/SqlTransform.java | 3 +-
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 10 +--
.../sql/impl/rel/BeamAggregationRel.java | 24 +++-----
.../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 17 ++---
.../sql/impl/rel/BeamEnumerableConverter.java | 3 +-
.../sdk/extensions/sql/impl/rel/BeamIOSinkRel.java | 22 +++----
.../extensions/sql/impl/rel/BeamIOSourceRel.java | 11 ++--
.../extensions/sql/impl/rel/BeamIntersectRel.java | 18 +-----
.../sdk/extensions/sql/impl/rel/BeamJoinRel.java | 49 +++++++++------
.../sdk/extensions/sql/impl/rel/BeamMinusRel.java | 17 +----
.../sdk/extensions/sql/impl/rel/BeamRelNode.java | 29 +++++++--
.../sql/impl/rel/BeamSetOperatorRelBase.java | 30 ++++-----
.../sdk/extensions/sql/impl/rel/BeamSortRel.java | 12 ++--
.../extensions/sql/impl/rel/BeamSqlRelUtils.java | 72 +++++++++-------------
.../extensions/sql/impl/rel/BeamUncollectRel.java | 16 ++---
.../sdk/extensions/sql/impl/rel/BeamUnionRel.java | 17 +----
.../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 30 +++++----
.../sdk/extensions/sql/impl/rel/BeamValuesRel.java | 15 ++---
.../sql/impl/schema/BeamPCollectionTable.java | 8 +--
.../meta/provider/bigquery/BeamBigQueryTable.java | 23 +++----
.../sql/meta/provider/kafka/BeamKafkaTable.java | 32 ++++------
.../meta/provider/pubsub/PubsubIOJsonTable.java | 8 +--
.../sql/meta/provider/text/BeamTextCSVTable.java | 10 ++-
.../sdk/extensions/sql/BeamSqlDslJoinTest.java | 4 +-
.../sdk/extensions/sql/PubsubToBigqueryIT.java | 4 +-
.../sql/impl/parser/TestTableProvider.java | 27 ++------
.../sdk/extensions/sql/impl/rel/BaseRelTest.java | 3 +-
.../sql/impl/rel/BeamEnumerableConverterTest.java | 23 +++----
.../rel/BeamJoinRelUnboundedVsBoundedTest.java | 7 +--
...BeamSqlBuiltinFunctionsIntegrationTestBase.java | 2 +-
.../BeamSqlComparisonOperatorsIntegrationTest.java | 2 +-
.../meta/provider/bigquery/BigQueryWriteIT.java | 6 +-
.../sql/meta/provider/pubsub/PubsubJsonIT.java | 4 +-
.../meta/provider/text/BeamTextCSVTableTest.java | 13 ++--
.../extensions/sql/mock/MockedBoundedTable.java | 44 +++++--------
.../beam/sdk/extensions/sql/mock/MockedTable.java | 3 +-
.../extensions/sql/mock/MockedUnboundedTable.java | 11 ++--
39 files changed, 266 insertions(+), 376 deletions(-)
