liferoad commented on code in PR #34614:
URL: https://github.com/apache/beam/pull/34614#discussion_r2040271584
##########
sdks/python/apache_beam/transforms/sql_test.py:
##########
@@ -209,6 +209,30 @@ def test_map(self):
| SqlTransform("SELECT * FROM PCOLLECTION WHERE shopper = 'alice'"))
assert_that(out, equal_to([('alice', {'apples': 2, 'bananas': 3})]))
+ def test_sql_ddl_set_option(self):
+ with TestPipeline() as p:
+ input_data = [
+ beam.Row(id=1, value=10),
+ beam.Row(id=2, value=20),
+ beam.Row(id=3, value=30)
+ ]
+ # DDL uses SET to modify a session option (tests DDL parsing)
+ # Using a known Calcite option like sqlConformance
+ ddl_statement = """
Review Comment:
this is more like a dumpy test. Not very familiar with the DDL support under
Beam. Use this dumpy one for now.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@beam.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
