|
0
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 9
}
sort {
input...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 9
}
sort {
input...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:04
|
10 s
|
[0][1][2][3]
|
|
1
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 19
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:14
|
4 s
|
[4][5][6][7]
|
|
2
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 29
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:19
|
3 s
|
[8][9][10][11]
|
|
3
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 39
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:22
|
3 s
|
[12][13][14][15]
|
|
4
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 49
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:25
|
2 s
|
[16][17][18][19]
|
|
5
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 59
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:27
|
2 s
|
[20][21][22][23]
|
|
6
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 69
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:29
|
2 s
|
[24][25][26][27]
|
|
7
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 79
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:31
|
2 s
|
[28][29][30][31]
|
|
8
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 89
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:33
|
2 s
|
[32][33][34][35]
|
|
9
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 99
}
sort {
inpu...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:35
|
2 s
|
[36][37][38][39]
|
|
10
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 109
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:37
|
2 s
|
[40][41][42][43]
|
|
11
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 119
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:39
|
2 s
|
[44][45][46][47]
|
|
12
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 129
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:41
|
2 s
|
[48][49][50][51]
|
|
13
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 139
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:43
|
2 s
|
[52][53][54][55]
|
|
14
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 149
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:45
|
2 s
|
[56][57][58][59]
|
|
15
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 159
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:46
|
1 s
|
[60][61][62][63]
|
|
16
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 169
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:48
|
1 s
|
[64][65][66][67]
|
|
17
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 179
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:49
|
1 s
|
[68][69][70][71]
|
|
18
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 189
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:51
|
1 s
|
[72][73][74][75]
|
|
19
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 199
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:52
|
1 s
|
[76][77][78][79]
|
|
20
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 209
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:54
|
1 s
|
[80][81][82][83]
|
|
21
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 219
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:55
|
1 s
|
[84][85][86][87]
|
|
22
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 229
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:57
|
1 s
|
[88][89][90][91]
|
|
23
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 239
}
sort {
inp...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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 12:58:58
|
1 s
|
[92][93][94][95]
|
|
24
|
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 242
}
show_string {
...
+details
Spark Connect - session_id: "d9678789-255e-4b0b-9606-13461ef38296"
plan {
root {
common {
plan_id: 242
}
show_string {
...
session_id: "d9678789-255e-4b0b-9606-13461ef38296"
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: "6ddbfa93-bfc1-437f-9e6a-eb0721ec2a14"
client_observed_server_side_session_id: "8e04356e-3559-4ba8-ba45-887b68eb54e7"
|
2026/03/19 13:01:53
|
0.2 s
|
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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
|
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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
|
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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]
|
|
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
|
|