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/06/12 01:38:23 UTC
[beam] branch master updated (42e45e2 -> 63cc13a)
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 42e45e2 Merge pull request #11988 from robinyqiu/cleanup
add 63cc13a Support HOP and SESSION as TVF (#11868)
No new revisions were added by this update.
Summary of changes:
.../extensions/sql/impl/TVFSlidingWindowFn.java | 75 +++
.../sql/impl/rel/BeamTableFunctionScanRel.java | 198 +++++++-
.../sql/impl/utils/TVFStreamingUtils.java | 9 +
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 36 +-
.../beam/sdk/extensions/sql/zetasql/TestInput.java | 52 +-
.../zetasql/translation/ExpressionConverter.java | 79 ++-
.../extensions/sql/zetasql/StreamingSQLTest.java | 550 +++++++++++++++++++++
.../sql/zetasql/ZetaSQLDialectSpecTest.java | 293 +----------
.../extensions/sql/zetasql/ZetaSQLTestBase.java | 122 +++++
9 files changed, 1076 insertions(+), 338 deletions(-)
create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TVFSlidingWindowFn.java
create mode 100644 sdks/java/extensions/sql/zetasql/src/test/java/org/apache/beam/sdk/extensions/sql/zetasql/StreamingSQLTest.java
create mode 100644 sdks/java/extensions/sql/zetasql/src/test/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLTestBase.java