Skip to content

Commit

Permalink
Update snapshots for rename to SelectSqlQueryToDataTableTask.
Browse files Browse the repository at this point in the history
  • Loading branch information
@plypaul
plypaul committed May 31, 2024
1 parent 6969321 commit e4c430f
Show file tree
Hide file tree
Showing 28 changed files with 56 additions and 56 deletions.
4 changes: 2 additions & 2 deletions ...test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' ds__day\n' -->
<!-- ' , is_instant') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...snapshots/test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -28,5 +28,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' is_instant\n' -->
<!-- ' , listing__country_latest') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions .../test_dataflow_to_execution.py/ExecutionPlan/BigQuery/test_multihop_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -37,5 +37,5 @@
<!-- ' )\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' account_id__customer_id__customer_name') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...ataflow_to_execution.py/ExecutionPlan/BigQuery/test_small_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -43,5 +43,5 @@
<!-- ' subq_4.is_instant = subq_9.is_instant\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' is_instant') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...st_dataflow_to_execution.py/ExecutionPlan/Databricks/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n' -->
<!-- ' , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...apshots/test_dataflow_to_execution.py/ExecutionPlan/Databricks/test_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -28,5 +28,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' subq_2.is_instant\n' -->
<!-- ' , listings_latest_src_28000.country') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...est_dataflow_to_execution.py/ExecutionPlan/Databricks/test_multihop_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -37,5 +37,5 @@
<!-- ' )\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' subq_14.customer_id__customer_name') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...aflow_to_execution.py/ExecutionPlan/Databricks/test_small_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -43,5 +43,5 @@
<!-- ' subq_4.is_instant = subq_9.is_instant\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.is_instant, subq_9.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...s/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n' -->
<!-- ' , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...w/snapshots/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -28,5 +28,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' subq_2.is_instant\n' -->
<!-- ' , listings_latest_src_28000.country') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...ts/test_dataflow_to_execution.py/ExecutionPlan/DuckDB/test_multihop_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -37,5 +37,5 @@
<!-- ' )\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' subq_14.customer_id__customer_name') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ..._dataflow_to_execution.py/ExecutionPlan/DuckDB/test_small_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -43,5 +43,5 @@
<!-- ' subq_4.is_instant = subq_9.is_instant\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.is_instant, subq_9.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n' -->
<!-- ' , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...snapshots/test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -28,5 +28,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' subq_2.is_instant\n' -->
<!-- ' , listings_latest_src_28000.country') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions .../test_dataflow_to_execution.py/ExecutionPlan/Postgres/test_multihop_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -37,5 +37,5 @@
<!-- ' )\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' subq_14.customer_id__customer_name') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...ataflow_to_execution.py/ExecutionPlan/Postgres/test_small_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -43,5 +43,5 @@
<!-- ' subq_4.is_instant = subq_9.is_instant\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.is_instant, subq_9.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n' -->
<!-- ' , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...snapshots/test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -28,5 +28,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' subq_2.is_instant\n' -->
<!-- ' , listings_latest_src_28000.country') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions .../test_dataflow_to_execution.py/ExecutionPlan/Redshift/test_multihop_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -37,5 +37,5 @@
<!-- ' )\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' subq_14.customer_id__customer_name') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...ataflow_to_execution.py/ExecutionPlan/Redshift/test_small_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -43,5 +43,5 @@
<!-- ' subq_4.is_instant = subq_9.is_instant\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.is_instant, subq_9.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...est_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n' -->
<!-- ' , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...napshots/test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -28,5 +28,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' subq_2.is_instant\n' -->
<!-- ' , listings_latest_src_28000.country') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...test_dataflow_to_execution.py/ExecutionPlan/Snowflake/test_multihop_joined_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -37,5 +37,5 @@
<!-- ' )\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' subq_14.customer_id__customer_name') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...taflow_to_execution.py/ExecutionPlan/Snowflake/test_small_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -43,5 +43,5 @@
<!-- ' subq_4.is_instant = subq_9.is_instant\n' -->
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.is_instant, subq_9.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
4 changes: 2 additions & 2 deletions ...ts/test_dataflow_to_execution.py/ExecutionPlan/Trino/test_combined_metrics_plan__ep_0.xml
View file
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
<ExecutionPlan>
<SelectSqlQueryToDataFrameTask>
<SelectSqlQueryToDataTableTask>
<!-- description = 'Run a query and write the results to a data frame' -->
<!-- node_id = NodeId(id_str='rsq_0') -->
<!-- sql_query = -->
Expand Down Expand Up @@ -82,5 +82,5 @@
<!-- 'GROUP BY\n' -->
<!-- ' COALESCE(subq_4.ds__day, subq_9.ds__day, subq_14.ds__day)\n' -->
<!-- ' , COALESCE(subq_4.is_instant, subq_9.is_instant, subq_14.is_instant)') -->
</SelectSqlQueryToDataFrameTask>
</SelectSqlQueryToDataTableTask>
</ExecutionPlan>
Loading

0 comments on commit e4c430f

Please sign in to comment.