py: update demos to use register_output_view

abhizer · ryzhyk · commit 01ce9dad1a2e · 2024-06-19T10:21:55.000-07:00
Signed-off-by: Abhinav Gyawali &lt;22275402+abhizer@users.noreply.github.com&gt;
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -20,6 +20,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - API: Demos are supplied by specifying a local directory rather than URLs,
   and the demos endpoint returns the demos directly.
   ([#1890](https://github.com/feldera/feldera/pull/1890))
+- [Python] Support for `register_local_view` and rename`register_view`
+  to `register_output_view` ([#1884](https://github.com/feldera/feldera/pull/1884))
 
 ## [0.18.0] - 2024-06-11
 
diff --git a/demo/project_demo10-FraudDetectionDeltaLake/notebook.ipynb b/demo/project_demo10-FraudDetectionDeltaLake/notebook.ipynb
@@ -186,7 +186,7 @@
     "          window_30_day AS (PARTITION BY t.cc_num ORDER BY unix_time RANGE BETWEEN 2592000 PRECEDING AND CURRENT ROW);\n",
     "      \"\"\"\n",
     "\n",
-    "    sql.register_view(\"FEATURE\", query)\n",
+    "    sql.register_output_view(\"FEATURE\", query)\n",
     "    return sql\n"
    ]
   },
diff --git a/demo/project_demo10-FraudDetectionDeltaLake/run.py b/demo/project_demo10-FraudDetectionDeltaLake/run.py
@@ -278,7 +278,7 @@ def build_program(client, pipeline_name):
           window_30_day AS (PARTITION BY t.cc_num ORDER BY unix_time RANGE BETWEEN 2592000 PRECEDING AND CURRENT ROW);
       """
 
-    sql.register_view("FEATURE", query)
+    sql.register_output_view("FEATURE", query)
     return sql
 
 # Split input dataframe into train and test sets
diff --git a/docs/use_cases/fraud_detection/fraud_detection.md b/docs/use_cases/fraud_detection/fraud_detection.md
@@ -181,7 +181,7 @@ def build_program(client, pipeline_name):
           window_30_day AS (PARTITION BY t.cc_num ORDER BY unix_time RANGE BETWEEN 2592000 PRECEDING AND CURRENT ROW);
       """
 
-    sql.register_view("FEATURE", query)
+    sql.register_output_view("FEATURE", query)
     return sql
 ```
 
diff --git a/python/docs/examples.rst b/python/docs/examples.rst
@@ -45,7 +45,7 @@ to to call :meth:`.SQLContext.listen` before you call
     # here, we provide a query, that gets registered as a view in feldera
     # this query will be executed on the data in the table
     query = f"SELECT name, ((science + maths + art) / 3) as average FROM {TBL_NAMES[0]} JOIN {TBL_NAMES[1]} on id = student_id ORDER BY average DESC"
-    sql.register_view(view_name, query)
+    sql.register_output_view(view_name, query)
 
     # connect the source (a pandas Dataframe in this case) to the tables
     sql.connect_source_pandas(TBL_NAMES[0], df_students)
@@ -129,7 +129,7 @@ More on Kafka as the output connector at: https://www.feldera.com/docs/connector
 
     sql = SQLContext('kafka', 'http://localhost:8080').get_or_create()
     sql.register_table(TABLE_NAME, SQLSchema({"id": "INT NOT NULL PRIMARY KEY"}))
-    sql.register_view(VIEW_NAME, f"SELECT COUNT(*) as num_rows FROM {TABLE_NAME}")
+    sql.register_output_view(VIEW_NAME, f"SELECT COUNT(*) as num_rows FROM {TABLE_NAME}")
 
     source_config = {
         "topics": ["example_topic"],
@@ -183,7 +183,7 @@ More on the HTTP GET connector at: https://www.feldera.com/docs/connectors/sourc
 
     sql.register_table(TBL_NAME, SQLSchema({"id": "INT", "name": "STRING"}))
 
-    sql.register_view(VIEW_NAME, f"SELECT * FROM {TBL_NAME}")
+    sql.register_output_view(VIEW_NAME, f"SELECT * FROM {TBL_NAME}")
 
     path = "https://feldera-basics-tutorial.s3.amazonaws.com/part.json"
 
diff --git a/python/docs/introduction.rst b/python/docs/introduction.rst
@@ -82,7 +82,7 @@ Key Concepts
 
          # Register Views based on your queries
          query = f"SELECT * FROM {tbl_name}"
-         sql.register_view(view_name, query)
+         sql.register_output_view(view_name, query)
 
          # name for this connector
          in_con = "delta_input_conn"

Original file line number	Diff line number	Diff line change
`@@ -186,7 +186,7 @@`
`186`	`186`	`" window_30_day AS (PARTITION BY t.cc_num ORDER BY unix_time RANGE BETWEEN 2592000 PRECEDING AND CURRENT ROW);\n",`
`187`	`187`	`" \"\"\"\n",`
`188`	`188`	`"\n",`
`189`		`- " sql.register_view(\"FEATURE\", query)\n",`
	`189`	`+ " sql.register_output_view(\"FEATURE\", query)\n",`
`190`	`190`	`" return sql\n"`
`191`	`191`	`]`
`192`	`192`	`},`