Skip to content

Accept pragma risks in ESQL challenge in NYC Taxis #813

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gbanasiak merged 1 commit into from
Jul 9, 2025
Merged

Accept pragma risks in ESQL challenge in NYC Taxis #813

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
55 changes: 44 additions & 11 deletions nyc_taxis/operations/default.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -966,7 +966,10 @@
"name": "avg_passenger_count_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | stats avg(passenger_count)",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1010,7 +1013,10 @@
"name": "avg_tip_percent_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | where fare_amount > 0 | eval tip_percent = tip_amount / fare_amount | stats avg(tip_percent)",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1049,7 +1055,10 @@
"name": "avg_amount_group_by_integer_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | stats avg(total_amount) by passenger_count | sort passenger_count",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1088,7 +1097,10 @@
"name": "avg_amount_group_by_keyword_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | stats avg(total_amount) by rate_code_id | sort rate_code_id",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1117,7 +1129,10 @@
"name": "count_group_by_keyword_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | stats count=count(*) by rate_code_id | sort count desc",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1163,7 +1178,10 @@
"name": "avg_passenger_count_filtered_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | where total_amount > 60 and rate_code_id==\"2\"| stats avg(passenger_count)",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand All @@ -1189,7 +1207,10 @@
"name": "sort_by_ts_esql_doc_partitioning",
"operation-type": "esql",
"query" : "FROM nyc_taxis | sort pickup_datetime desc | KEEP pickup_datetime, dropoff_datetime, trip_distance | LIMIT 1000",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand All @@ -1202,7 +1223,10 @@
"name": "date_histogram_calendar_interval_esql_doc_partitioning",
"operation-type": "esql",
"query": "FROM nyc_taxis | where dropoff_datetime < \"2015-03-01T00:00:00\" AND dropoff_datetime >= \"2015-01-01T00:00:00\" | eval dropoffs_over_time=date_trunc(1 week, dropoff_datetime) | stats c = count(dropoff_datetime) by dropoffs_over_time | sort dropoffs_over_time",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand All @@ -1215,7 +1239,10 @@
"name": "date_histogram_fixed_interval_esql_doc_partitioning",
"operation-type": "esql",
"query": "FROM nyc_taxis | where dropoff_datetime < \"2015-03-01T00:00:00\" AND dropoff_datetime >= \"2015-01-01T00:00:00\" | eval dropoffs_over_time=date_trunc(10 days, dropoff_datetime) | stats c = count(dropoff_datetime) by dropoffs_over_time | sort dropoffs_over_time",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1274,7 +1301,10 @@
"name": "date_histogram_fixed_interval_with_metrics_esql_doc_partitioning",
"operation-type": "esql",
"query": "FROM nyc_taxis | where dropoff_datetime < \"2015-03-01T00:00:00\" AND dropoff_datetime >= \"2015-01-01T00:00:00\" | eval dropoffs_over_time=date_trunc(10 days, dropoff_datetime) | stats min_total_amount = min(total_amount), max_total_amount = max(total_amount), avg_total_amount = avg(total_amount), avg_trip_distance = avg(trip_distance) by dropoffs_over_time | sort dropoffs_over_time",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down Expand Up @@ -1314,7 +1344,10 @@
"name": "multi_terms-keyword_esql_doc_partitioning",
"operation-type": "esql",
"query": "FROM nyc_taxis | where dropoff_datetime < \"2015-02-01T00:00:00\" AND dropoff_datetime >= \"2015-01-01T00:00:00\" | stats c = count(dropoff_datetime) by trip_type, payment_type, vendor_id",
"body": { "pragma": { "data_partitioning": "doc" } }
"body": {
"accept_pragma_risks": true,
"pragma": { "data_partitioning": "doc" }
}
},
{%- endif -%}{# non-serverless-doc-partitioning-marker-end #}
{
Expand Down
Loading