diff --git a/queries/.gitignore b/queries/.gitignore new file mode 100644 index 0000000..1fcb152 --- /dev/null +++ b/queries/.gitignore @@ -0,0 +1 @@ +out diff --git a/queries/highest.sql b/queries/highest.sql new file mode 100644 index 0000000..ab19b02 --- /dev/null +++ b/queries/highest.sql @@ -0,0 +1 @@ +SELECT max(slot) FROM slot_status WHERE toDate(timestamp) = today() diff --git a/queries/race.sql b/queries/race.sql new file mode 100644 index 0000000..e69de29 diff --git a/queries/single_slot.sql b/queries/single_slot.sql new file mode 100644 index 0000000..5965225 --- /dev/null +++ b/queries/single_slot.sql @@ -0,0 +1,13 @@ +SELECT slot, + timestamp, + runningDifference(toUnixTimestamp64Milli(timestamp)) AS deltaMs, + bar(deltaMs, 0, 10000, 10) AS deltaMsB, + type +FROM ( + SELECT * + FROM slot_status + WHERE (slot = 138604605) + AND (source = 'val4.ffm1') + ORDER BY timestamp ASC, + type ASC + ) diff --git a/queries/slot_ts.sql b/queries/slot_ts.sql new file mode 100644 index 0000000..a9fdb29 --- /dev/null +++ b/queries/slot_ts.sql @@ -0,0 +1,9 @@ +WITH CAST(timestamp, 'Nullable(DateTime)') AS ts +SELECT + slot, + minIf(ts, type = 'firstShredReceived') AS first, + minIf(ts, type = 'completed') AS completed, + minIf(ts, type = 'optimisticConfirmation') AS confirmed +FROM slot_status +GROUP BY slot +ORDER BY slot ASC diff --git a/queries/tx_per_leader.sql b/queries/tx_per_leader.sql new file mode 100644 index 0000000..a1aebb6 --- /dev/null +++ b/queries/tx_per_leader.sql @@ -0,0 +1,4 @@ +select leader, avg(stats.num_successful_transactions + assumeNotNull(stats.num_failed_transactions)) as avgTxs +from slot_status +group by leader +order by avgTxs desc diff --git a/queries/tx_per_slot.sql b/queries/tx_per_slot.sql new file mode 100644 index 0000000..e9901c9 --- /dev/null +++ b/queries/tx_per_slot.sql @@ -0,0 +1,7 @@ +SELECT + slot, + max(assumeNotNull(stats.num_successful_transactions)) + max(assumeNotNull(stats.num_failed_transactions)) AS maxTxs +FROM slot_status +WHERE type = 'frozen' +GROUP BY slot +ORDER BY slot diff --git a/queries/winner_winner_chicken_dinner.sql b/queries/winner_winner_chicken_dinner.sql new file mode 100644 index 0000000..2201f1e --- /dev/null +++ b/queries/winner_winner_chicken_dinner.sql @@ -0,0 +1,29 @@ +SELECT + winner, + count(), + bar(count(), 1, 10000, 20) +FROM + ( + SELECT + slot, + any(source) AS winner + FROM + ( + SELECT + source, + slot, + minIf(timestamp, type = 'completed') AS firstCompleted + FROM slot_status + WHERE toDate(timestamp) = today() + GROUP BY + source, + slot + ORDER BY + slot ASC, + firstCompleted ASC + ) + GROUP BY slot + ORDER BY slot ASC + ) +GROUP BY winner +ORDER BY count() DESC