You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2020/05/19 04:45:00 UTC
[beam] branch master updated (a70fde0 -> bd4523b)
This is an automated email from the ASF dual-hosted git repository.
amaliujia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a70fde0 [BEAM-9339] Ensure that Dataflow's pipeline proto also contains the capabilities (#11748)
add bd4523b [BEAM-9363] TUMBLE as TVF (#10946)
No new revisions were added by this update.
Summary of changes:
.../src/main/resources/beam/suppressions.xml | 1 +
.../extensions/sql/impl/planner/BeamRuleSets.java | 3 +-
.../sql/impl/rel/BeamTableFunctionScanRel.java | 162 +++++++++++++++++++++
.../sql/impl/rule/BeamTableFunctionScanRule.java | 71 +++++++++
.../{package-info.java => TVFStreamingUtils.java} | 8 +-
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 47 +++++-
.../sql/zetasql/SqlWindowTableFunction.java | 116 +++++++++++++++
.../zetasql/translation/ExpressionConverter.java | 64 ++++++++
.../translation/QueryStatementConverter.java | 2 +
.../sql/zetasql/translation/TVFScanConverter.java | 86 +++++++++++
.../sql/zetasql/ZetaSQLDialectSpecTest.java | 40 +++++
11 files changed, 594 insertions(+), 6 deletions(-)
create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamTableFunctionScanRel.java
create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamTableFunctionScanRule.java
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/{package-info.java => TVFStreamingUtils.java} (80%)
create mode 100644 sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlWindowTableFunction.java
create mode 100644 sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TVFScanConverter.java