Commit Graph

205 Commits

Author SHA1 Message Date
jeremyhi fa0f571655 feat: add interval option in heartbeat response (#298)
* feat: add interval option in heartbeat response

Signed-off-by: jeremyhi <fengjiachun@gmail.com>

* feat: HeartbeatConfig

Signed-off-by: jeremyhi <fengjiachun@gmail.com>

* chore: remove unnecessary optional

Signed-off-by: jeremyhi <fengjiachun@gmail.com>

---------

Signed-off-by: jeremyhi <fengjiachun@gmail.com>
2026-01-06 12:01:39 +08:00
Weny Xu a2e5099d72 feat: use path for ApplyStagingManifestRequest (#297)
Signed-off-by: WenyXu <wenymedia@gmail.com>
2025-12-30 14:57:56 +08:00
Weny Xu 520fa524f9 feat: introduce ApplyStagingManifestRequest (#296)
Signed-off-by: WenyXu <wenymedia@gmail.com>
2025-12-24 16:30:08 +08:00
Ning Sun 173efe5ec6 feat: define CommentOn task (#295)
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
Co-authored-by: Ruihang Xia <waynestxia@gmail.com>
2025-12-18 12:41:40 +08:00
Ning Sun 5b7d43d7bf feat: update prometheus remote write proto file for native histogram (#294)
* feat: update prometheus remote write proto file for native histogram

* chore: format
2025-12-12 11:45:34 +08:00
Sicong Hu 0df99f09f1 feat: add BuildIndexRequest to RegionRequestHeader (#291)
* feat: add `BuildIndexRequest` to `RegionRequestHeader`

Signed-off-by: SNC123 <sinhco@outlook.com>

* fix: make all

Signed-off-by: SNC123 <sinhco@outlook.com>

---------

Signed-off-by: SNC123 <sinhco@outlook.com>
2025-11-24 22:18:19 -08:00
Ruihang Xia 437e6a1ef8 feat: add Dictionary to ColumnDataType (#290) 2025-11-21 18:45:21 +08:00
LFC fd699b2199 refactor: make json value a dedicated message (#289) 2025-11-17 15:17:51 +08:00
zyy17 14b9dc40bd feat: add total_cpu_millicores/total_memory_bytes/cpu_usage_millicores/memory_usage_bytes (#287) 2025-10-23 10:56:23 +08:00
discord9 72a0d22e0f Revert "feat: add total_cpu_millicores/total_memory_bytes/`cpu_usage_mill…" (#286)
This reverts commit 9d93fc3363.

Co-authored-by: zyy17 <zyylsxm@gmail.com>
2025-10-22 16:23:02 +08:00
discord9 d9541cd111 feat: substrait extension logical node use column index not name (#285)
* feat: use index for sub ext plan

Signed-off-by: discord9 <discord9@163.com>

* make all

Signed-off-by: discord9 <discord9@163.com>

* chore: update typos

Signed-off-by: discord9 <discord9@163.com>

---------

Signed-off-by: discord9 <discord9@163.com>
2025-10-22 15:55:10 +08:00
zyy17 9d93fc3363 feat: add total_cpu_millicores/total_memory_bytes/cpu_usage_millicores/memory_usage_bytes (#284) 2025-10-22 15:55:00 +08:00
fys 69a6089933 feat: support-for-and-keep-firing-for-trigger (#282) 2025-10-17 12:07:43 +08:00
Lei, HUANG 710f1fa95c feat: add parallelism to compaction request (#280)
Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>
2025-10-16 11:46:55 +08:00
zyy17 8d31a8cd39 refactor: add hostname field in NodeInfo and use it in MetasrvNodeInfo (#278) 2025-10-16 10:57:57 +08:00
Ning Sun a250938d71 feat: add new json format (#281)
* feat: add new json format

* refactor: rename native format

* chore: store nested data type in json_native_extension

* feat: use json as a concrete type in proto

* Revert "feat: add `BuildIndexRequest` to `RegionRequestHeader` (#276)"

This reverts commit ee46a0eeaa.
2025-10-15 15:23:35 +08:00
Sicong Hu ee46a0eeaa feat: add BuildIndexRequest to RegionRequestHeader (#276)
Signed-off-by: SNC123 <sinhco@outlook.com>
2025-10-13 10:38:48 +08:00
Ning Sun d75496d5d0 feat: add struct and list data type (#277)
* feat: add struct and list data type

* type extensions

* feat: extend column type

* chore: rename fields

* add value enum item

* feat: add value

* refactor: item->items

* feat: use single ListValue/StructValue for Row and Column
2025-10-09 11:07:20 +08:00
discord9 3e821d0d40 feat: add extension to heartbeat request (#275)
* feat: add extension to heartbeat request

Signed-off-by: discord9 <discord9@163.com>

* make all

Signed-off-by: discord9 <discord9@163.com>

---------

Signed-off-by: discord9 <discord9@163.com>
2025-09-19 12:23:19 +08:00
Weny Xu f9836cf8aa feat: add memory_bytes field (#274) 2025-09-08 16:32:11 +08:00
discord9 66eb089afa feat: flow add eval interval (#273)
* feat: create flow eval interval

Signed-off-by: discord9 <discord9@163.com>

* fix: eval interval

Signed-off-by: discord9 <discord9@163.com>

* chore: make all

Signed-off-by: discord9 <discord9@163.com>

* fix: flow create request

Signed-off-by: discord9 <discord9@163.com>

* chore: make all

Signed-off-by: discord9 <discord9@163.com>

* chore: fmt

Signed-off-by: discord9 <discord9@163.com>

---------

Signed-off-by: discord9 <discord9@163.com>
2025-08-27 16:21:27 +08:00
fys 4ce7e9a3ff refactor: enhanced trigger interval (#269)
* fix: improve interval precision

* chore: better name

* chore: add /opt/include to proto include

* remove empty line
2025-08-18 10:58:28 +08:00
Zhenchi 9edc8c4d2a feat: add partition to CreateRequest (#267) 2025-08-13 14:39:49 -07:00
Weny Xu 69680846a0 feat: add TopicStat (#268)
* feat: add `TopicStat`

* chore: generate code
2025-08-13 19:21:39 +08:00
discord9 ccfd4da48b feat: truncate request by time ranges (#262)
* feat: truncate request by time ranges

Signed-off-by: discord9 <discord9@163.com>

* fix: default time unit is millisecond

Signed-off-by: discord9 <discord9@163.com>

* refactor: per review

Signed-off-by: discord9 <discord9@163.com>

* add time ranges to truncate table expr

Signed-off-by: discord9 <discord9@163.com>

* chore: make all

Signed-off-by: discord9 <discord9@163.com>

* chore: fmt

Signed-off-by: discord9 <discord9@163.com>

* chore: make all

Signed-off-by: discord9 <discord9@163.com>

* chore: make all

Signed-off-by: discord9 <discord9@163.com>

---------

Signed-off-by: discord9 <discord9@163.com>
2025-08-04 18:17:40 +08:00
Weny Xu 91c3d7b97a feat: introduce reconcile interface (#264)
* feat: introduce reconcile interface

* chore: gen set_header

* chore: add comments

* feat: return procedure_id

* feat: add `ResolveStragey` and `Parallelism` to request

* chore: apply suggestions from CR
2025-08-04 16:50:33 +08:00
Ruihang Xia cc56a6cdac feat: absent function in PromQL (#263)
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
2025-08-04 16:27:00 +08:00
Weny Xu fe8c13f5f3 feat: introduce SyncColumns (#261) 2025-07-30 11:47:09 +08:00
Lin Yihai 3bb33593a7 feat: Support SET DEFAULT syntax (#251)
Signed-off-by: Yihai Lin <yihai-lin@foxmail.com>
2025-07-29 11:19:12 +08:00
Zhenchi 7fcaa3e413 feat: deprecate Region::Partition use partition expr instead (#256)
* feat: deprecate Region::Partition use partition expr instead

Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>

* merge origin/main

Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>

* put partition expr into Partition

Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>

---------

Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>
2025-07-23 10:30:51 +08:00
Weny Xu 36116a5c24 feat: introduce SetIndexes and UnsetIndexes (#253) 2025-07-22 10:50:09 +08:00
fys 855dff1b87 chore: format proto file (#254)
* chore: proto file format using buf

* generate go file
2025-07-16 11:25:57 +08:00
Zhenchi ceb1af4fa9 feat: add granularity and false_positive_rate options for indexes (#249)
Signed-off-by: Zhenchi <zhongzc_arch@outlook.com>
2025-07-02 15:00:28 +08:00
fys 464226cf8a feat: support trigger drop (#248)
* feat: add trigger-drop proto

* remove trigger id of DropTriggerExpr
2025-06-24 11:06:43 -07:00
Yingwen 819a949550 feat: Add ListMetadataRequest (#247)
* feat: add ListMetadataRequest

Signed-off-by: evenyag <realevenyag@gmail.com>

* chore: generate C++ and java codes

Signed-off-by: evenyag <realevenyag@gmail.com>

* chore: document return value

Signed-off-by: evenyag <realevenyag@gmail.com>

---------

Signed-off-by: evenyag <realevenyag@gmail.com>
2025-06-23 14:39:46 +08:00
Lin Yihai 82fe5c6282 feat: add DROP DEFAULT (#246)
Signed-off-by: Yihai Lin <yihai-lin@foxmail.com>
2025-06-17 16:19:39 +08:00
Lei, HUANG fdcbe5f1c7 chore: add connection id to Process (#245)
* add connection id to Process

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

* feat/add-connection-id-to-process-info:
 **Update `server.proto` for ProcessInfo Message**

 - Changed the data type of `id` from `uint64` to `uint32` in the `ProcessInfo` message.
 - Removed the `connection_id` field from the `ProcessInfo` message.

 Affected file:
 - `proto/greptime/v1/frontend/server.proto`

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

* feat/add-connection-id-to-process-info:
 Update `process_id` type in `server.proto`

 - Changed the data type of `process_id` from `uint64` to `uint32` in `proto/greptime/v1/frontend/server.proto` to align with system requirements.

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

---------

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>
2025-06-16 20:40:59 -07:00
discord9 1797152367 feat(flow): bulk notify (#243)
* feat: mark dirty time window

* fix: time window range

* update DirtyWindowRequest

---------

Co-authored-by: Lei, HUANG <mrsatangel@gmail.com>
2025-06-16 14:16:14 +08:00
Lei, HUANG f0913f179e feat: kill process rpc service (#244)
* feat/kill-process:
 ### Add KillProcess RPC Method

 - **Added `KillProcess` RPC Method**: Introduced a new RPC method `KillProcess` in the `Frontend` service to allow killing a running process on the frontend.
   - Updated files: `server.grpc.pb.cc`, `server.grpc.pb.h`, `server.pb.cc`, `server.pb.h`, `server.proto`
   - Added new request and response messages: `KillProcessRequest` and `KillProcessResponse`.

 - **Java Bindings**: Updated Java bindings to include the new `KillProcess` method.
   - Updated file: `Server.java`

* feat/kill-process:
 **Update `server.proto` for KillProcessRequest and KillProcessResponse**

 - Added `server_addr` field to `KillProcessRequest` for specifying the frontend server address.
 - Changed field numbers for `catalog` and `process_id` in `KillProcessRequest`.
 - Enhanced `KillProcessResponse` to include a `found` boolean indicating if the target process was located.

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>

* rename found to success

---------

Signed-off-by: Lei, HUANG <mrsatangel@gmail.com>
2025-06-13 20:53:07 +08:00
Lei, HUANG 5f6119ac79 feat: frontend server (#242)
* feat/frontend-server
 ### Add Frontend Service Protocol Buffers
 - Introduced a new Protocol Buffers file `server.proto` in `proto/greptime/v1/frontend/`.
 - Defined the `Frontend` service with an RPC method `ListProcess`.
 - Added message definitions for `ListProcessRequest`, `ListProcessResponse`, and `ProcessInfo`.
 - Included fields for process ID, catalog, schema, query, start timestamp, and client information in `ProcessInfo`.

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* feat/frontend-server:
 ### Update `server.proto` in `greptime/v1/frontend`

 - Added a newline at the end of the `ProcessInfo` message definition in `server.proto`.

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* feat/frontend-server:
 Add new proto file to build script

 - Updated `build.rs` to include `proto/greptime/v1/frontend/server.proto` in the build process.

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* add frontend mod

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* feat/frontend-server:
 **Add Frontend Info to ProcessInfo**

 - Updated `server.proto` to include a new field `frontend` in the `ProcessInfo` message, providing additional frontend information for processes.

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* feat/frontend-server:
 Update `server.proto` to modify data types and field names

 - Changed the data type of `id` from `uint64` to `string` in `ProcessInfo`.
 - Renamed field `schema` to `schemas` in `ProcessInfo`.

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* -

Signed-off-by: Lei, HUANG <lhuang@greptime.com>

* add catalog to ListProcessRequest

---------

Signed-off-by: Lei, HUANG <lhuang@greptime.com>
2025-06-12 10:45:14 +08:00
fys 454c52634c feat: add proto definition about trigger create (#241)
* feat: add trigger create

* chore: unified naming style

* chore: rename some fields

* chore: make all
2025-06-04 11:12:55 +08:00
Lei, HUANG ecaefd1da7 feat: bulk wal entry (#239)
* Add bulk wal entry

* add sequence

* move arrow ipc to common
2025-05-29 17:10:13 +08:00
Lei, HUANG 67ee5f94e5 Add data header to requests (#240) 2025-05-23 14:18:52 +08:00
Ruihang Xia 4d4136692f feat: add time index column to series divide plan (#238)
Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
2025-05-21 19:27:49 -07:00
Weny Xu 7668a882d5 feat: introduce node workloads (#235)
* feat: introduce node workloads

* feat: add feature gate

* chore: apply suggestions from CR
2025-05-09 17:35:49 +08:00
Lei, HUANG 187acde93b feat: remove region selection (#237)
* feat/remove-region-selection:
 ### Refactor `ArrowIpc` and Remove `RegionSelection`

 - **Refactor `ArrowIpc` Structure**:
   - Moved `region_id` to be the first field in `ArrowIpc`.
   - Removed `region_selection` field from `ArrowIpc`.
   - Updated field numbers for `schema` and `payload` in `ArrowIpc`.
   - Affected files: `server.pb.cc`, `server.pb.h`, `Server.java`, `server.proto`.

 - **Remove `RegionSelection` Message**:
   - Deleted the `RegionSelection` message and its related code.
   - Affected files: `server.pb.cc`, `server.pb.h`, `Server.java`, `server.proto`.

 These changes streamline the `ArrowIpc` message structure and remove unused `RegionSelection` components.

* dummy
2025-05-09 12:16:06 +08:00
LFC 159e92d30b feat: sst_min_sequences in QueryContext (#234) 2025-05-07 20:59:51 +08:00
Lei, HUANG bdca8e50e4 fix: restore region selection to avoid breaking main branch (#236) 2025-05-07 11:02:58 +08:00
Lei, HUANG 754d20f5ef refactor: add selection to bulk (#232)
* feat: add selection field to BulkInsertRequest

* add schema section

* change bulk request

* replace vec<u8> with bytes

* wip

* wip

* chore: rebase main

* fix: clippy

* refactor arrow ipc writes
2025-05-06 17:10:53 +08:00
discord9 e82b0158cd feat: add insert into logical plan in request (#231)
* feat: insert into logical plan

* chore: make all

* feat: use TableName instead

* chore: make all

* chore: per review
2025-04-18 20:03:23 +08:00