|
9
|
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 21
}
show_string {
input {
common {
plan_id: 20
}
limit {
input {
common {
plan_id: 19
}
sort {
input {
common {
}
aggregate {
}
}
order {
child {
}
direction: SORT_DIRECTION_DESCENDING
null_ordering: SORT_NULLS_LAST
}
is_global: true
}
}
limit: 20
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "1e03df46-960e-4d65-920d-c0bd8e406fef"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
|
2026/04/27 09:08:53
|
34 s
|
[16][17]
|
|
8
|
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 15
}
show_string {
input {
common {
plan_id: 14
}
filter {
input {
common {
plan_id: 13
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.base_uniswap_v3_token_transfer_features_all_01"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "bb82d8fe-41a5-4a5a-8fb8-3de21be5f0f3"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
|
2026/04/27 09:08:02
|
14 s
|
[13][14][15]
|
|
7
|
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 12
}
show_string {
input {
common {
plan_id: 11
}
filter {
input {
common {
plan_id: 10
}
read {
named_table {
unparsed_identifier: "iceberg_us.research.one_day_transfer_full_aggr"
}
}
}
condition {
unresolved_function {
function_name: "=="
arguments {
unresolved_function {
}
}
arguments {
literal {
}
common {
}
}
}
common {
origin {
python_origin {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "f6a1a898-1446-46a1-9f72-a309d38029b0"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
|
2026/04/27 09:07:33
|
29 s
|
[9][10][11][12]
|
|
6
|
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 9
}
show_string {
input {
common {
plan_id: 8
}
project {
input {
common {
plan_id: 7
}
read {
named_table {
unparsed_identifier: "iceberg_us.base_logs.prod_raw_transfers"
}
}
}
expressions {
unresolved_function {
function_name: "min"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
expressions {
unresolved_function {
function_name: "max"
arguments {
unresolved_attribute {
}
common {
}
}
}
}
}
}
num_rows: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "975457c3-d5f4-4166-883f-9d94fbe15378"
client_observed_server_side_session_id: "68cd703f-4261-407b-9ff2-76c9ed5303a6"
|
2026/04/27 09:07:25
|
2 s
|
[7][8]
|
|
5
|
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "c87f77b3-6c44-47a8-990e-96ec673076b2"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
show_string {
input {
common {
plan_id: 5
}
aggregate {
input {
common {
plan_id: 4
}
with_columns {
input {
common {
}
with_columns {
}
}
aliases {
expr {
}
name: "value"
}
}
}
group_type: GROUP_TYPE_GROUPBY
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "day"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
grouping_expressions {
unresolved_attribute {
unparsed_identifier: "address"
is_metadata_column: false
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "n_transfers"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
}
}
name: "transfer_volume"
}
common {
origin {
python_origin {
}
}
}
}
aggregate_expressions {
alias {
expr {
unresolved_function {
...
|
2026/04/27 09:06:40
|
7 s
|
[4][5][6]
|
|
4
|
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 8
}
catalog {
list_databases {
}
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "7bc419ab-3320-4035-bff0-77ac964f795e"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
|
2026/04/27 09:05:14
|
10 ms
|
|
|
3
|
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 6
}
catalog {
list_databases {
}
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "2473580f-9455-4952-894a-4b0cf3d6ba21"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
|
2026/04/27 09:05:09
|
20 ms
|
|
|
2
|
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 4
}
catalog {
list_tables {
db_name: "iceberg_us.research"
}
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "3355de98-46bd-415f-8619-54e4888eac93"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
|
2026/04/27 09:04:55
|
0.1 s
|
|
|
0
|
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
+details
Spark Connect - session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_...
session_id: "f68b086b-b940-4db2-bdee-a44106cae4d0"
user_context {
user_id: "dev"
}
plan {
root {
common {
plan_id: 2
}
show_string {
input {
common {
plan_id: 1
}
sql {
query: "SELECT 1"
}
}
num_rows: 20
truncate: 20
}
}
}
client_type: "_SPARK_CONNECT_PYTHON spark/4.1.1 os/linux python/3.11.2"
request_options {
result_chunking_options {
allow_arrow_batch_chunking: true
}
}
request_options {
reattach_options {
reattachable: true
}
}
operation_id: "de735bb7-bd47-441a-9272-d9afd874d1d0"
client_observed_server_side_session_id: "59e154d3-d333-4a5e-95d5-8197b68dd98e"
|
2026/04/27 09:03:52
|
6 s
|
[0]
|