|
124
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 242
}
show_string {
...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 242
}
show_string {
...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 242
}
show_string {
input {
common {
plan_id: 241
}
to_df {
input {
common {
plan_id: 240
}
local_relation {
data: "\377\377\377\377h\001\000\000[truncated(size=1,472)]"
}
}
column_names: "segment"
column_names: "total_rows"
column_names: "total_unique_customers"
column_names: "total_events"
column_names: "total_weighted_amount"
column_names: "avg_amount_over_chunks"
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.6"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "f81f909a-d292-406e-b535-8c15dac5c532"
client_observed_server_side_session_id: "03501823-3c83-4e79-82fa-be10a155e0c0"
|
2026/03/19 14:15:48
|
24 ms
|
|
|
123
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 239
}
sort {
input {
common {
plan_id: 238
}
aggregate {
input {
common {
plan_id: 237
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:47
|
1 s
|
[476][477][478][479]
|
|
122
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 229
}
sort {
input {
common {
plan_id: 228
}
aggregate {
input {
common {
plan_id: 227
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:46
|
1 s
|
[472][473][474][475]
|
|
121
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 219
}
sort {
input {
common {
plan_id: 218
}
aggregate {
input {
common {
plan_id: 217
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:44
|
1.0 s
|
[468][469][470][471]
|
|
120
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 209
}
sort {
input {
common {
plan_id: 208
}
aggregate {
input {
common {
plan_id: 207
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:43
|
1 s
|
[464][465][466][467]
|
|
119
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 199
}
sort {
input {
common {
plan_id: 198
}
aggregate {
input {
common {
plan_id: 197
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:42
|
1.0 s
|
[460][461][462][463]
|
|
118
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 189
}
sort {
input {
common {
plan_id: 188
}
aggregate {
input {
common {
plan_id: 187
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:41
|
1 s
|
[456][457][458][459]
|
|
117
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 179
}
sort {
input {
common {
plan_id: 178
}
aggregate {
input {
common {
plan_id: 177
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:40
|
1 s
|
[452][453][454][455]
|
|
116
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 169
}
sort {
input {
common {
plan_id: 168
}
aggregate {
input {
common {
plan_id: 167
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:39
|
1 s
|
[448][449][450][451]
|
|
115
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 159
}
sort {
input {
common {
plan_id: 158
}
aggregate {
input {
common {
plan_id: 157
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:38
|
1 s
|
[444][445][446][447]
|
|
114
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 149
}
sort {
input {
common {
plan_id: 148
}
aggregate {
input {
common {
plan_id: 147
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:36
|
1 s
|
[440][441][442][443]
|
|
113
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 139
}
sort {
input {
common {
plan_id: 138
}
aggregate {
input {
common {
plan_id: 137
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:35
|
1.0 s
|
[436][437][438][439]
|
|
112
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 129
}
sort {
input {
common {
plan_id: 128
}
aggregate {
input {
common {
plan_id: 127
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:34
|
1 s
|
[432][433][434][435]
|
|
111
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 119
}
sort {
input {
common {
plan_id: 118
}
aggregate {
input {
common {
plan_id: 117
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:33
|
1 s
|
[428][429][430][431]
|
|
110
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 109
}
sort {
input {
common {
plan_id: 108
}
aggregate {
input {
common {
plan_id: 107
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:32
|
1 s
|
[424][425][426][427]
|
|
109
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 99
}
sort {
input {
common {
plan_id: 98
}
aggregate {
input {
common {
plan_id: 97
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:31
|
1 s
|
[420][421][422][423]
|
|
108
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 89
}
sort {
input {
common {
plan_id: 88
}
aggregate {
input {
common {
plan_id: 87
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:30
|
1.0 s
|
[416][417][418][419]
|
|
107
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 79
}
sort {
input {
common {
plan_id: 78
}
aggregate {
input {
common {
plan_id: 77
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:28
|
1 s
|
[412][413][414][415]
|
|
106
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 69
}
sort {
input {
common {
plan_id: 68
}
aggregate {
input {
common {
plan_id: 67
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:27
|
1 s
|
[408][409][410][411]
|
|
105
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 59
}
sort {
input {
common {
plan_id: 58
}
aggregate {
input {
common {
plan_id: 57
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:26
|
1 s
|
[404][405][406][407]
|
|
104
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 49
}
sort {
input {
common {
plan_id: 48
}
aggregate {
input {
common {
plan_id: 47
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:25
|
1 s
|
[400][401][402][403]
|
|
103
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 39
}
sort {
input {
common {
plan_id: 38
}
aggregate {
input {
common {
plan_id: 37
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:24
|
1 s
|
[396][397][398][399]
|
|
102
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 29
}
sort {
input {
common {
plan_id: 28
}
aggregate {
input {
common {
plan_id: 27
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:22
|
1 s
|
[392][393][394][395]
|
|
101
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 19
}
sort {
input {
common {
plan_id: 18
}
aggregate {
input {
common {
plan_id: 17
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 14:15:21
|
1 s
|
[388][389][390][391]
|
|
100
|
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 9
}
sort {
input...
+details
Spark Connect - session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 9
}
sort {
input...
session_id: "e5b26c6b-417b-4f37-a626-ee8e4cdf2ffb"
plan {
root {
common {
plan_id: 9
}
sort {
input {
common {
plan_id: 8
}
aggregate {
input {
common {
plan_id: 7
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
...
|
2026/03/19 14:15:19
|
2 s
|
[384][385][386][387]
|
|
99
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 242
}
show_string {
...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 242
}
show_string {
...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 242
}
show_string {
input {
common {
plan_id: 241
}
to_df {
input {
common {
plan_id: 240
}
local_relation {
data: "\377\377\377\377h\001\000\000[truncated(size=1,472)]"
}
}
column_names: "segment"
column_names: "total_rows"
column_names: "total_unique_customers"
column_names: "total_events"
column_names: "total_weighted_amount"
column_names: "avg_amount_over_chunks"
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.6"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "1919db0c-ce43-41db-b38c-6a4b59084738"
client_observed_server_side_session_id: "26bec19f-b754-4002-a244-21d3af42a298"
|
2026/03/19 13:37:36
|
41 ms
|
|
|
98
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 239
}
sort {
input {
common {
plan_id: 238
}
aggregate {
input {
common {
plan_id: 237
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:34
|
1 s
|
[380][381][382][383]
|
|
97
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 229
}
sort {
input {
common {
plan_id: 228
}
aggregate {
input {
common {
plan_id: 227
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:33
|
1 s
|
[376][377][378][379]
|
|
96
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 219
}
sort {
input {
common {
plan_id: 218
}
aggregate {
input {
common {
plan_id: 217
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:32
|
1 s
|
[372][373][374][375]
|
|
95
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 209
}
sort {
input {
common {
plan_id: 208
}
aggregate {
input {
common {
plan_id: 207
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:30
|
1 s
|
[368][369][370][371]
|
|
94
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 199
}
sort {
input {
common {
plan_id: 198
}
aggregate {
input {
common {
plan_id: 197
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:29
|
1 s
|
[364][365][366][367]
|
|
93
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 189
}
sort {
input {
common {
plan_id: 188
}
aggregate {
input {
common {
plan_id: 187
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:28
|
1 s
|
[360][361][362][363]
|
|
92
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 179
}
sort {
input {
common {
plan_id: 178
}
aggregate {
input {
common {
plan_id: 177
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:27
|
1 s
|
[356][357][358][359]
|
|
91
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 169
}
sort {
input {
common {
plan_id: 168
}
aggregate {
input {
common {
plan_id: 167
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:25
|
1 s
|
[352][353][354][355]
|
|
90
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 159
}
sort {
input {
common {
plan_id: 158
}
aggregate {
input {
common {
plan_id: 157
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:24
|
1 s
|
[348][349][350][351]
|
|
89
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 149
}
sort {
input {
common {
plan_id: 148
}
aggregate {
input {
common {
plan_id: 147
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:23
|
1 s
|
[344][345][346][347]
|
|
88
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 139
}
sort {
input {
common {
plan_id: 138
}
aggregate {
input {
common {
plan_id: 137
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:22
|
1 s
|
[340][341][342][343]
|
|
87
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 129
}
sort {
input {
common {
plan_id: 128
}
aggregate {
input {
common {
plan_id: 127
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:21
|
1 s
|
[336][337][338][339]
|
|
86
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 119
}
sort {
input {
common {
plan_id: 118
}
aggregate {
input {
common {
plan_id: 117
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:19
|
1 s
|
[332][333][334][335]
|
|
85
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 109
}
sort {
input {
common {
plan_id: 108
}
aggregate {
input {
common {
plan_id: 107
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:18
|
1 s
|
[328][329][330][331]
|
|
84
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 99
}
sort {
input {
common {
plan_id: 98
}
aggregate {
input {
common {
plan_id: 97
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:17
|
1 s
|
[324][325][326][327]
|
|
83
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 89
}
sort {
input {
common {
plan_id: 88
}
aggregate {
input {
common {
plan_id: 87
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:16
|
1 s
|
[320][321][322][323]
|
|
82
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 79
}
sort {
input {
common {
plan_id: 78
}
aggregate {
input {
common {
plan_id: 77
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:15
|
1 s
|
[316][317][318][319]
|
|
81
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 69
}
sort {
input {
common {
plan_id: 68
}
aggregate {
input {
common {
plan_id: 67
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:13
|
1 s
|
[312][313][314][315]
|
|
80
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 59
}
sort {
input {
common {
plan_id: 58
}
aggregate {
input {
common {
plan_id: 57
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:12
|
1 s
|
[308][309][310][311]
|
|
79
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 49
}
sort {
input {
common {
plan_id: 48
}
aggregate {
input {
common {
plan_id: 47
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:11
|
1 s
|
[304][305][306][307]
|
|
78
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 39
}
sort {
input {
common {
plan_id: 38
}
aggregate {
input {
common {
plan_id: 37
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:09
|
1 s
|
[300][301][302][303]
|
|
77
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 29
}
sort {
input {
common {
plan_id: 28
}
aggregate {
input {
common {
plan_id: 27
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:08
|
1 s
|
[296][297][298][299]
|
|
76
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 19
}
sort {
input {
common {
plan_id: 18
}
aggregate {
input {
common {
plan_id: 17
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:37:07
|
1 s
|
[292][293][294][295]
|
|
75
|
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 9
}
sort {
input...
+details
Spark Connect - session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 9
}
sort {
input...
session_id: "58c17781-cbfb-4961-ab16-dfcc29ca85c9"
plan {
root {
common {
plan_id: 9
}
sort {
input {
common {
plan_id: 8
}
aggregate {
input {
common {
plan_id: 7
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
...
|
2026/03/19 13:37:05
|
2 s
|
[288][289][290][291]
|
|
74
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 242
}
show_string {
...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 242
}
show_string {
...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 242
}
show_string {
input {
common {
plan_id: 241
}
to_df {
input {
common {
plan_id: 240
}
local_relation {
data: "\377\377\377\377h\001\000\000[truncated(size=1,472)]"
}
}
column_names: "segment"
column_names: "total_rows"
column_names: "total_unique_customers"
column_names: "total_events"
column_names: "total_weighted_amount"
column_names: "avg_amount_over_chunks"
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.6"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "ecb14661-3719-4d06-a697-dfe833bd94a6"
client_observed_server_side_session_id: "b208f11e-c9ba-4a72-a901-4f334530fb0a"
|
2026/03/19 13:29:35
|
48 ms
|
|
|
73
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 239
}
sort {
input {
common {
plan_id: 238
}
aggregate {
input {
common {
plan_id: 237
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:33
|
1 s
|
[284][285][286][287]
|
|
72
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 229
}
sort {
input {
common {
plan_id: 228
}
aggregate {
input {
common {
plan_id: 227
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:32
|
1 s
|
[280][281][282][283]
|
|
71
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 219
}
sort {
input {
common {
plan_id: 218
}
aggregate {
input {
common {
plan_id: 217
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:31
|
1 s
|
[276][277][278][279]
|
|
70
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 209
}
sort {
input {
common {
plan_id: 208
}
aggregate {
input {
common {
plan_id: 207
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:30
|
1 s
|
[272][273][274][275]
|
|
69
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 199
}
sort {
input {
common {
plan_id: 198
}
aggregate {
input {
common {
plan_id: 197
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:28
|
1 s
|
[268][269][270][271]
|
|
68
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 189
}
sort {
input {
common {
plan_id: 188
}
aggregate {
input {
common {
plan_id: 187
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:27
|
1 s
|
[264][265][266][267]
|
|
67
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 179
}
sort {
input {
common {
plan_id: 178
}
aggregate {
input {
common {
plan_id: 177
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:26
|
1 s
|
[260][261][262][263]
|
|
66
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 169
}
sort {
input {
common {
plan_id: 168
}
aggregate {
input {
common {
plan_id: 167
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:25
|
1 s
|
[256][257][258][259]
|
|
65
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 159
}
sort {
input {
common {
plan_id: 158
}
aggregate {
input {
common {
plan_id: 157
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:23
|
1 s
|
[252][253][254][255]
|
|
64
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 149
}
sort {
input {
common {
plan_id: 148
}
aggregate {
input {
common {
plan_id: 147
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:22
|
1 s
|
[248][249][250][251]
|
|
63
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 139
}
sort {
input {
common {
plan_id: 138
}
aggregate {
input {
common {
plan_id: 137
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:21
|
1 s
|
[244][245][246][247]
|
|
62
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 129
}
sort {
input {
common {
plan_id: 128
}
aggregate {
input {
common {
plan_id: 127
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:19
|
1 s
|
[240][241][242][243]
|
|
61
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 119
}
sort {
input {
common {
plan_id: 118
}
aggregate {
input {
common {
plan_id: 117
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:18
|
1 s
|
[236][237][238][239]
|
|
60
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 109
}
sort {
input {
common {
plan_id: 108
}
aggregate {
input {
common {
plan_id: 107
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:17
|
1 s
|
[232][233][234][235]
|
|
59
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 99
}
sort {
input {
common {
plan_id: 98
}
aggregate {
input {
common {
plan_id: 97
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:15
|
1 s
|
[228][229][230][231]
|
|
58
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 89
}
sort {
input {
common {
plan_id: 88
}
aggregate {
input {
common {
plan_id: 87
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:14
|
1 s
|
[224][225][226][227]
|
|
57
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 79
}
sort {
input {
common {
plan_id: 78
}
aggregate {
input {
common {
plan_id: 77
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:13
|
1 s
|
[220][221][222][223]
|
|
56
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 69
}
sort {
input {
common {
plan_id: 68
}
aggregate {
input {
common {
plan_id: 67
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:11
|
1 s
|
[216][217][218][219]
|
|
55
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 59
}
sort {
input {
common {
plan_id: 58
}
aggregate {
input {
common {
plan_id: 57
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:10
|
1 s
|
[212][213][214][215]
|
|
54
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 49
}
sort {
input {
common {
plan_id: 48
}
aggregate {
input {
common {
plan_id: 47
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:09
|
1 s
|
[208][209][210][211]
|
|
53
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 39
}
sort {
input {
common {
plan_id: 38
}
aggregate {
input {
common {
plan_id: 37
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:07
|
1 s
|
[204][205][206][207]
|
|
52
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 29
}
sort {
input {
common {
plan_id: 28
}
aggregate {
input {
common {
plan_id: 27
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:06
|
1 s
|
[200][201][202][203]
|
|
51
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 19
}
sort {
input {
common {
plan_id: 18
}
aggregate {
input {
common {
plan_id: 17
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:29:05
|
1 s
|
[196][197][198][199]
|
|
50
|
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 9
}
sort {
input...
+details
Spark Connect - session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 9
}
sort {
input...
session_id: "9c50851a-1acc-4eb3-9800-52decc69a7c4"
plan {
root {
common {
plan_id: 9
}
sort {
input {
common {
plan_id: 8
}
aggregate {
input {
common {
plan_id: 7
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
...
|
2026/03/19 13:29:03
|
2 s
|
[192][193][194][195]
|
|
49
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 242
}
show_string {
...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 242
}
show_string {
...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 242
}
show_string {
input {
common {
plan_id: 241
}
to_df {
input {
common {
plan_id: 240
}
local_relation {
data: "\377\377\377\377h\001\000\000[truncated(size=1,472)]"
}
}
column_names: "segment"
column_names: "total_rows"
column_names: "total_unique_customers"
column_names: "total_events"
column_names: "total_weighted_amount"
column_names: "avg_amount_over_chunks"
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.6"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "cfab0a43-1921-4404-8026-4269adbf8b27"
client_observed_server_side_session_id: "816d6fa8-b07a-4604-b784-3cafa957680f"
|
2026/03/19 13:20:06
|
29 ms
|
|
|
48
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 239
}
sort {
input {
common {
plan_id: 238
}
aggregate {
input {
common {
plan_id: 237
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:20:04
|
1 s
|
[188][189][190][191]
|
|
47
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 229
}
sort {
input {
common {
plan_id: 228
}
aggregate {
input {
common {
plan_id: 227
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:20:03
|
1 s
|
[184][185][186][187]
|
|
46
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 219
}
sort {
input {
common {
plan_id: 218
}
aggregate {
input {
common {
plan_id: 217
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:20:02
|
1 s
|
[180][181][182][183]
|
|
45
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 209
}
sort {
input {
common {
plan_id: 208
}
aggregate {
input {
common {
plan_id: 207
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:20:00
|
1 s
|
[176][177][178][179]
|
|
44
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 199
}
sort {
input {
common {
plan_id: 198
}
aggregate {
input {
common {
plan_id: 197
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:59
|
1 s
|
[172][173][174][175]
|
|
43
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 189
}
sort {
input {
common {
plan_id: 188
}
aggregate {
input {
common {
plan_id: 187
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:58
|
1 s
|
[168][169][170][171]
|
|
42
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 179
}
sort {
input {
common {
plan_id: 178
}
aggregate {
input {
common {
plan_id: 177
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:56
|
1 s
|
[164][165][166][167]
|
|
41
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 169
}
sort {
input {
common {
plan_id: 168
}
aggregate {
input {
common {
plan_id: 167
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:55
|
1 s
|
[160][161][162][163]
|
|
40
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 159
}
sort {
input {
common {
plan_id: 158
}
aggregate {
input {
common {
plan_id: 157
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:54
|
1 s
|
[156][157][158][159]
|
|
39
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 149
}
sort {
input {
common {
plan_id: 148
}
aggregate {
input {
common {
plan_id: 147
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:52
|
1 s
|
[152][153][154][155]
|
|
38
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 139
}
sort {
input {
common {
plan_id: 138
}
aggregate {
input {
common {
plan_id: 137
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:51
|
1 s
|
[148][149][150][151]
|
|
37
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 129
}
sort {
input {
common {
plan_id: 128
}
aggregate {
input {
common {
plan_id: 127
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:50
|
1 s
|
[144][145][146][147]
|
|
36
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 119
}
sort {
input {
common {
plan_id: 118
}
aggregate {
input {
common {
plan_id: 117
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:48
|
1 s
|
[140][141][142][143]
|
|
35
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 109
}
sort {
input {
common {
plan_id: 108
}
aggregate {
input {
common {
plan_id: 107
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:47
|
1 s
|
[136][137][138][139]
|
|
34
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 99
}
sort {
input {
common {
plan_id: 98
}
aggregate {
input {
common {
plan_id: 97
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:46
|
1 s
|
[132][133][134][135]
|
|
33
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 89
}
sort {
input {
common {
plan_id: 88
}
aggregate {
input {
common {
plan_id: 87
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:44
|
1 s
|
[128][129][130][131]
|
|
32
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 79
}
sort {
input {
common {
plan_id: 78
}
aggregate {
input {
common {
plan_id: 77
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:43
|
1 s
|
[124][125][126][127]
|
|
31
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 69
}
sort {
input {
common {
plan_id: 68
}
aggregate {
input {
common {
plan_id: 67
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:41
|
1 s
|
[120][121][122][123]
|
|
30
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 59
}
sort {
input {
common {
plan_id: 58
}
aggregate {
input {
common {
plan_id: 57
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:40
|
1 s
|
[116][117][118][119]
|
|
29
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 49
}
sort {
input {
common {
plan_id: 48
}
aggregate {
input {
common {
plan_id: 47
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:38
|
1 s
|
[112][113][114][115]
|
|
28
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 39
}
sort {
input {
common {
plan_id: 38
}
aggregate {
input {
common {
plan_id: 37
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:37
|
1 s
|
[108][109][110][111]
|
|
27
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 29
}
sort {
input {
common {
plan_id: 28
}
aggregate {
input {
common {
plan_id: 27
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:36
|
1 s
|
[104][105][106][107]
|
|
26
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 19
}
sort {
input {
common {
plan_id: 18
}
aggregate {
input {
common {
plan_id: 17
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
...
|
2026/03/19 13:19:34
|
1 s
|
[100][101][102][103]
|
|
25
|
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 9
}
sort {
input...
+details
Spark Connect - session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 9
}
sort {
input...
session_id: "3baaf123-80a1-4cdf-9896-5fc6f62868d9"
plan {
root {
common {
plan_id: 9
}
sort {
input {
common {
plan_id: 8
}
aggregate {
input {
common {
plan_id: 7
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "weighted_amount"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "segment"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "processing_day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "row_count"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "unique_customers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
...
|
2026/03/19 13:19:32
|
2 s
|
[96][97][98][99]
|