| 25 |
AdaptiveSparkPlan isFinalPlan=false
+- Project [token_address#17, transfer_date#18, transfer_count#19L, admission_date#25]
+- BroadcastHashJoin [token_address#17], [token_address#22], Inner, BuildRight, false
:- HashAggregate(keys=[token_address#17, transfer_date#18], functions=[count(1)], output=[token_address#17, transfer_date#18, transfer_count#19L])
: +- Exchange hashpartitioning(token_address#17, transfer_date#18, 200), ENSURE_REQUIREMENTS, [plan_id=49]
: +- HashAggregate(keys=[token_address#17, transfer_date#18], functions=[partial_count(1)], output=[token_address#17, transfer_date#18, count#58L])
: +- Project [lower(address#35) AS token_address#17, cast(datetime#28 as date) AS transfer_date#18]
: +- Filter ((((((((isnotnull(block_number#26) AND (block_number#26 >= 1937534)) AND (block_number#26 <= 40171326)) AND (datetime#28 >= 2023-07-30 00:00:00)) AND (datetime#28 < 2025-12-31 00:00:00)) AND (topic0#38 = 0xddf252ad1be2c89b69c2b068fc378daa952ba...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
43.2 MiB |
0.0 B |
| 37 |
AdaptiveSparkPlan isFinalPlan=false
+- Project [token_address#190, transfer_date#191, transfer_count#192L, admission_date#198]
+- BroadcastHashJoin [token_address#190], [token_address#195], Inner, BuildRight, false
:- HashAggregate(keys=[token_address#190, transfer_date#191], functions=[count(1)], output=[token_address#190, transfer_date#191, transfer_count#192L])
: +- Exchange hashpartitioning(token_address#190, transfer_date#191, 200), ENSURE_REQUIREMENTS, [plan_id=150]
: +- HashAggregate(keys=[token_address#190, transfer_date#191], functions=[partial_count(1)], output=[token_address#190, transfer_date#191, count#231L])
: +- Project [lower(address#208) AS token_address#190, cast(datetime#201 as date) AS transfer_date#191]
: +- Filter ((((((((isnotnull(block_number#199) AND (block_number#199 >= 1937534)) AND (block_number#199 <= 40171326)) AND (datetime#201 >= 2023-07-30 00:00:00)) AND (datetime#201 < 2025-12-31 00:00:00)) AND (topic0#211 = 0xddf252ad...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
43.1 MiB |
0.0 B |
| 88 |
AdaptiveSparkPlan isFinalPlan=false
+- Project [token_address#669, transfer_date#670, transfer_count#671L, admission_date#677]
+- BroadcastHashJoin [token_address#669], [token_address#674], Inner, BuildRight, false
:- HashAggregate(keys=[token_address#669, transfer_date#670], functions=[count(1)], output=[token_address#669, transfer_date#670, transfer_count#671L])
: +- Exchange hashpartitioning(token_address#669, transfer_date#670, 200), ENSURE_REQUIREMENTS, [plan_id=689]
: +- HashAggregate(keys=[token_address#669, transfer_date#670], functions=[partial_count(1)], output=[token_address#669, transfer_date#670, count#710L])
: +- Project [lower(address#687) AS token_address#669, cast(datetime#680 as date) AS transfer_date#670]
: +- Filter ((((((((isnotnull(block_number#678) AND (block_number#678 >= 1937534)) AND (block_number#678 <= 40171326)) AND (datetime#680 >= 2023-07-30 00:00:00)) AND (datetime#680 < 2025-12-31 00:00:00)) AND (topic0#690 = 0xddf252ad...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
43.1 MiB |
0.0 B |
| 406 |
AdaptiveSparkPlan isFinalPlan=false
+- Project [token_address#4097, transfer_date#4098, transfer_count#4099L, admission_date#4105]
+- BroadcastHashJoin [token_address#4097], [token_address#4102], Inner, BuildRight, false
:- HashAggregate(keys=[token_address#4097, transfer_date#4098], functions=[count(1)], output=[token_address#4097, transfer_date#4098, transfer_count#4099L])
: +- Exchange hashpartitioning(token_address#4097, transfer_date#4098, 200), ENSURE_REQUIREMENTS, [plan_id=5042]
: +- HashAggregate(keys=[token_address#4097, transfer_date#4098], functions=[partial_count(1)], output=[token_address#4097, transfer_date#4098, count#4138L])
: +- Project [lower(address#4115) AS token_address#4097, cast(datetime#4108 as date) AS transfer_date#4098]
: +- Filter ((((((((isnotnull(block_number#4106) AND (block_number#4106 >= 1937534)) AND (block_number#4106 <= 40171326)) AND (datetime#4108 >= 2023-07-30 00:00:00)) AND (datetime#4108 < 2025-12-31 00:00:00)) ...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
43.1 MiB |
0.0 B |
| 523 |
AdaptiveSparkPlan isFinalPlan=false
+- Project [token_address#5243, date#5244, transfer_count#5245L, admission_date#5251]
+- BroadcastHashJoin [token_address#5243], [token_address#5248], Inner, BuildRight, false
:- HashAggregate(keys=[token_address#5243, date#5244], functions=[count(1)], output=[token_address#5243, date#5244, transfer_count#5245L])
: +- Exchange hashpartitioning(token_address#5243, date#5244, 200), ENSURE_REQUIREMENTS, [plan_id=8180]
: +- HashAggregate(keys=[token_address#5243, date#5244], functions=[partial_count(1)], output=[token_address#5243, date#5244, count#5284L])
: +- Project [lower(address#5261) AS token_address#5243, cast(datetime#5254 as date) AS date#5244]
: +- Filter ((((((((isnotnull(block_number#5252) AND (block_number#5252 >= 1937534)) AND (block_number#5252 <= 40171326)) AND (datetime#5254 >= 2023-07-30 00:00:00)) AND (datetime#5254 < 2025-12-31 00:00:00)) AND (topic0#5264 = 0xddf252ad1be2c89b69c2b068fc378daa952ba7f163...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
43.2 MiB |
0.0 B |
| 559 |
AdaptiveSparkPlan isFinalPlan=false
+- HashAggregate(keys=[token_address#5586, date#5587], functions=[count(1)], output=[token_address#5586, date#5587, transfer_count#5588L])
+- Exchange hashpartitioning(token_address#5586, date#5587, 200), ENSURE_REQUIREMENTS, [plan_id=8624]
+- HashAggregate(keys=[token_address#5586, date#5587], functions=[partial_count(1)], output=[token_address#5586, date#5587, count#5621L])
+- Project [lower(address#5598) AS token_address#5586, cast(datetime#5591 as date) AS date#5587]
+- Filter ((((((((isnotnull(block_number#5589) AND (block_number#5589 >= 1937534)) AND (block_number#5589 <= 40171326)) AND (datetime#5591 >= 2023-07-30 00:00:00)) AND (datetime#5591 < 2025-12-31 00:00:00)) AND (topic0#5601 = 0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef)) AND isnotnull(topic1#5602)) AND isnotnull(topic2#5603)) AND NOT (lower(address#5598) = 0x4200000000000000000000000000000000000006))
+- BatchScan iceberg_us.base_logs.pro...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
1466.2 MiB |
0.0 B |
| 575 |
AdaptiveSparkPlan isFinalPlan=false
+- HashAggregate(keys=[token_address#5743, date#5744], functions=[count(1)], output=[token_address#5743, date#5744, transfer_count#5745L])
+- Exchange hashpartitioning(token_address#5743, date#5744, 200), ENSURE_REQUIREMENTS, [plan_id=8725]
+- HashAggregate(keys=[token_address#5743, date#5744], functions=[partial_count(1)], output=[token_address#5743, date#5744, count#5778L])
+- Project [lower(address#5755) AS token_address#5743, cast(datetime#5748 as date) AS date#5744]
+- Filter ((((((((isnotnull(block_number#5746) AND (block_number#5746 >= 1937534)) AND (block_number#5746 <= 40171326)) AND (datetime#5748 >= 2023-07-30 00:00:00)) AND (datetime#5748 < 2025-12-31 00:00:00)) AND (topic0#5758 = 0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef)) AND isnotnull(topic1#5759)) AND isnotnull(topic2#5760)) AND NOT (lower(address#5755) = 0x4200000000000000000000000000000000000006))
+- BatchScan iceberg_us.base_logs.pro...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
1465.8 MiB |
0.0 B |
| 700 |
AdaptiveSparkPlan isFinalPlan=false
+- HashAggregate(keys=[token_address#6781, date#6782], functions=[count(1)], output=[token_address#6781, date#6782, transfer_count#6783L])
+- Exchange hashpartitioning(token_address#6781, date#6782, 200), ENSURE_REQUIREMENTS, [plan_id=11409]
+- HashAggregate(keys=[token_address#6781, date#6782], functions=[partial_count(1)], output=[token_address#6781, date#6782, count#6816L])
+- Project [lower(address#6793) AS token_address#6781, cast(datetime#6786 as date) AS date#6782]
+- Filter ((((((((isnotnull(block_number#6784) AND (block_number#6784 >= 1937534)) AND (block_number#6784 <= 40171326)) AND (datetime#6786 >= 2023-07-30 00:00:00)) AND (datetime#6786 < 2025-12-31 00:00:00)) AND (topic0#6796 = 0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef)) AND isnotnull(topic1#6797)) AND isnotnull(topic2#6798)) AND NOT (lower(address#6793) = 0x4200000000000000000000000000000000000006))
+- BatchScan iceberg_us.base_logs.pr...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
1466.8 MiB |
0.0 B |
| 825 |
AdaptiveSparkPlan isFinalPlan=false
+- HashAggregate(keys=[token_address#7819, date#7820], functions=[count(1)], output=[token_address#7819, date#7820, transfer_count#7821L])
+- Exchange hashpartitioning(token_address#7819, date#7820, 200), ENSURE_REQUIREMENTS, [plan_id=14093]
+- HashAggregate(keys=[token_address#7819, date#7820], functions=[partial_count(1)], output=[token_address#7819, date#7820, count#7854L])
+- Project [lower(address#7831) AS token_address#7819, cast(datetime#7824 as date) AS date#7820]
+- Filter ((((((((isnotnull(block_number#7822) AND (block_number#7822 >= 1937534)) AND (block_number#7822 <= 40171326)) AND (datetime#7824 >= 2023-07-30 00:00:00)) AND (datetime#7824 < 2025-12-31 00:00:00)) AND (topic0#7834 = 0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef)) AND isnotnull(topic1#7835)) AND isnotnull(topic2#7836)) AND NOT (lower(address#7831) = 0x4200000000000000000000000000000000000006))
+- BatchScan iceberg_us.base_logs.pr...
|
Disk Memory Deserialized 1x Replicated
|
200 |
100.00% |
1466.7 MiB |
0.0 B |