chrislu
|
4d9de40c5c
|
fmt
|
2025-09-03 00:48:09 -07:00 |
|
chrislu
|
42661ac110
|
fix tests
|
2025-09-03 00:47:08 -07:00 |
|
chrislu
|
991247facf
|
fix tests
|
2025-09-03 00:40:03 -07:00 |
|
chrislu
|
e3e369c264
|
change to pg_query_go
|
2025-09-03 00:10:47 -07:00 |
|
chrislu
|
ba4a8b91d5
|
fmt
|
2025-09-02 22:31:53 -07:00 |
|
chrislu
|
59d6806146
|
fix empty spaces and coercion
|
2025-09-02 22:30:52 -07:00 |
|
chrislu
|
3fa7670557
|
fix todo
|
2025-09-02 22:12:47 -07:00 |
|
chrislu
|
687c5d6bfd
|
fix tests
|
2025-09-02 21:21:59 -07:00 |
|
chrislu
|
e14a316aeb
|
use schema instead of inferred result types
|
2025-09-02 20:59:13 -07:00 |
|
chrislu
|
a7eb178cec
|
Update engine.go
|
2025-09-02 18:37:31 -07:00 |
|
chrislu
|
60066a6a4c
|
read broker, logs, and parquet files
|
2025-09-02 18:15:26 -07:00 |
|
chrislu
|
d29f54e0be
|
de-support alter table and drop table
|
2025-09-02 17:23:46 -07:00 |
|
chrislu
|
8e15fdf2c7
|
remove sample data
|
2025-09-02 17:18:19 -07:00 |
|
chrislu
|
f776a49322
|
avoid sample data
|
2025-09-02 17:15:13 -07:00 |
|
chrislu
|
ed7102df6e
|
column name can be on left or right in where conditions
|
2025-09-02 17:05:31 -07:00 |
|
chrislu
|
e901abffd3
|
address comments
|
2025-09-02 15:40:38 -07:00 |
|
chrislu
|
586a795b02
|
return fast on error
|
2025-09-02 14:09:38 -07:00 |
|
chrislu
|
c9e093194d
|
setup integration test for postgres
|
2025-09-02 10:51:37 -07:00 |
|
chrislu
|
6fb88a8edb
|
buffer start stored as 8 bytes
|
2025-09-02 00:57:48 -07:00 |
|
chrislu
|
61bacd23b0
|
parquet file can query messages in broker memory, if log files do not exist
|
2025-09-02 00:49:12 -07:00 |
|
chrislu
|
618cb89885
|
the parquet file should also remember the first buffer_start attribute from the sources
|
2025-09-02 00:42:37 -07:00 |
|
chrislu
|
db75742e37
|
explain with broker buffer
|
2025-09-02 00:35:52 -07:00 |
|
chrislu
|
de866bfd09
|
dedup with buffer start index
|
2025-09-02 00:26:35 -07:00 |
|
chrislu
|
e3a56d7c30
|
filter out already flushed messages
|
2025-09-02 00:10:07 -07:00 |
|
chrislu
|
467034c8c7
|
process buffer from brokers
|
2025-09-01 23:45:52 -07:00 |
|
chrislu
|
7ca3b59c44
|
save source buffer index start for log files
|
2025-09-01 23:33:35 -07:00 |
|
chrislu
|
f5ed25f755
|
fix decoding data
|
2025-09-01 22:17:17 -07:00 |
|
chrislu
|
99bfe95e51
|
detailed logs during explain. Fix bugs on reading live logs.
|
2025-09-01 22:16:46 -07:00 |
|
chrislu
|
c7a0b89067
|
fix after refactoring
|
2025-09-01 21:40:24 -07:00 |
|
chrislu
|
e385f0ce7d
|
refactor
|
2025-09-01 20:19:59 -07:00 |
|
chrislu
|
61ad3c39ac
|
add tests
|
2025-09-01 20:05:24 -07:00 |
|
chrislu
|
4214d765cf
|
use mock for testing
|
2025-09-01 19:36:47 -07:00 |
|
chrislu
|
a3f6a5da27
|
skip
|
2025-09-01 18:55:14 -07:00 |
|
chrislu
|
dfd0897e49
|
improve tests
|
2025-09-01 18:52:22 -07:00 |
|
chrislu
|
7d88a81482
|
add tests
|
2025-09-01 18:00:55 -07:00 |
|
chrislu
|
eaa7136c92
|
explain the execution plan
|
2025-09-01 17:19:36 -07:00 |
|
chrislu
|
93a09f5da4
|
explain
|
2025-09-01 16:47:52 -07:00 |
|
chrislu
|
55cad6dc4a
|
combine parquet results with live logs
|
2025-09-01 16:26:35 -07:00 |
|
chrislu
|
e3798c2ec9
|
sql
|
2025-09-01 16:12:10 -07:00 |
|
chrislu
|
55dfb97fc8
|
parquet file generation remember the sources also
|
2025-09-01 15:11:06 -07:00 |
|
chrislu
|
2fa8991a52
|
scan all files
|
2025-09-01 14:51:23 -07:00 |
|
chrislu
|
c7598d89f1
|
remove emoji
|
2025-09-01 13:55:44 -07:00 |
|
chrislu
|
c73ceac79f
|
use parquet statistics for optimization
|
2025-09-01 13:50:56 -07:00 |
|
chrislu
|
471ba271dc
|
fix reading system fields
|
2025-09-01 13:28:38 -07:00 |
|
chrislu
|
8498240460
|
fmt
|
2025-09-01 13:09:44 -07:00 |
|
chrislu
|
8645f3a264
|
column name case insensitive, better auto column names
|
2025-09-01 11:25:04 -07:00 |
|
chrislu
|
32e73811f2
|
support aggregation functions
|
2025-09-01 11:15:00 -07:00 |
|
chrislu
|
cf9ad26608
|
scan topic messages
|
2025-09-01 10:50:01 -07:00 |
|
chrislu
|
ac8e6c8c82
|
actual column types
|
2025-09-01 08:56:27 -07:00 |
|
chrislu
|
49c0f74a1f
|
Update describe.go
|
2025-09-01 08:31:58 -07:00 |
|