mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2025-12-28 00:42:56 +00:00
4b36c285f1
* feat: adds Requester to process table flush and compaction request * feat: admin_fn macros for administration functions * test: add query result * feat: impl flush_region, flush_table, compact_region, and flush_region functions * docs: add Arguments to admin_fn macro * chore: apply suggestion Co-authored-by: Zhenchi <zhongzc_arch@outlook.com> * chore: apply suggestion Co-authored-by: Zhenchi <zhongzc_arch@outlook.com> * fix: group_requests_by_peer and adds log * Update src/common/macro/src/admin_fn.rs Co-authored-by: Ruihang Xia <waynestxia@gmail.com> * feat: adds todo for spawan thread * feat: rebase with main --------- Co-authored-by: Zhenchi <zhongzc_arch@outlook.com> Co-authored-by: Ruihang Xia <waynestxia@gmail.com>
67 lines
2.0 KiB
Plaintext
67 lines
2.0 KiB
Plaintext
--- test flush_region and compact_region ---
|
|
CREATE TABLE my_table (
|
|
a INT PRIMARY KEY,
|
|
b STRING,
|
|
ts TIMESTAMP TIME INDEX,
|
|
)
|
|
PARTITION ON COLUMNS (a) ();
|
|
|
|
Affected Rows: 0
|
|
|
|
INSERT INTO my_table VALUES
|
|
(1, 'a', 1),
|
|
(2, 'b', 2),
|
|
(11, 'c', 3),
|
|
(12, 'd', 4),
|
|
(21, 'e', 5),
|
|
(22, 'f', 5);
|
|
|
|
Affected Rows: 6
|
|
|
|
SELECT * FROM my_table;
|
|
|
|
+----+---+-------------------------+
|
|
| a | b | ts |
|
|
+----+---+-------------------------+
|
|
| 1 | a | 1970-01-01T00:00:00.001 |
|
|
| 2 | b | 1970-01-01T00:00:00.002 |
|
|
| 11 | c | 1970-01-01T00:00:00.003 |
|
|
| 12 | d | 1970-01-01T00:00:00.004 |
|
|
| 21 | e | 1970-01-01T00:00:00.005 |
|
|
| 22 | f | 1970-01-01T00:00:00.005 |
|
|
+----+---+-------------------------+
|
|
|
|
SELECT flush_region(greptime_partition_id) from information_schema.partitions WHERE table_name = 'my_table';
|
|
|
|
+-------------------------------------------------------------------+
|
|
| flush_region(information_schema.partitions.greptime_partition_id) |
|
|
+-------------------------------------------------------------------+
|
|
| 0 |
|
|
+-------------------------------------------------------------------+
|
|
|
|
SELECT compact_region(greptime_partition_id) from information_schema.partitions WHERE table_name = 'my_table';
|
|
|
|
+---------------------------------------------------------------------+
|
|
| compact_region(information_schema.partitions.greptime_partition_id) |
|
|
+---------------------------------------------------------------------+
|
|
| 0 |
|
|
+---------------------------------------------------------------------+
|
|
|
|
SELECT * FROM my_table;
|
|
|
|
+----+---+-------------------------+
|
|
| a | b | ts |
|
|
+----+---+-------------------------+
|
|
| 1 | a | 1970-01-01T00:00:00.001 |
|
|
| 2 | b | 1970-01-01T00:00:00.002 |
|
|
| 11 | c | 1970-01-01T00:00:00.003 |
|
|
| 12 | d | 1970-01-01T00:00:00.004 |
|
|
| 21 | e | 1970-01-01T00:00:00.005 |
|
|
| 22 | f | 1970-01-01T00:00:00.005 |
|
|
+----+---+-------------------------+
|
|
|
|
DROP TABLE my_table;
|
|
|
|
Affected Rows: 0
|
|
|