Merge branch 'main' into feat-dist-sql-analyze

Cargo.toml

@@ -93,7 +93,7 @@ bytes = "1"
 bytes_ext = { path = "components/bytes_ext" }
 catalog = { path = "catalog" }
 catalog_impls = { path = "catalog_impls" }
-ceresdbproto = { git = "https://github.com/baojinri/ceresdbproto.git", rev = "9b05108ea41b323c7ef7e54bb570b59cca5e76ed" }
+ceresdbproto = { git = "https://github.com/baojinri/ceresdbproto.git", rev = "9225d613f12e4d1fc12d976e8bbcde0eef76ce88" }
 codec = { path = "components/codec" }
 chrono = "0.4"
 clap = "3.0"

README-CN.md

@@ -1,40 +1,40 @@
-![CeresDB](docs/logo/CeresDB.png)
+![HoraeDB](docs/logo/CeresDB.png)
 
 ![License](https://img.shields.io/badge/license-Apache--2.0-green.svg)
-[![CI](https://github.com/CeresDB/ceresdb/actions/workflows/ci.yml/badge.svg)](https://github.com/CeresDB/ceresdb/actions/workflows/ci.yml)
-[![OpenIssue](https://img.shields.io/github/issues/CeresDB/ceresdb)](https://github.com/CeresDB/ceresdb/issues)
+[![CI](https://github.com/CeresDB/horaedb/actions/workflows/ci.yml/badge.svg)](https://github.com/CeresDB/horaedb/actions/workflows/ci.yml)
+[![OpenIssue](https://img.shields.io/github/issues/CeresDB/horaedb)](https://github.com/CeresDB/horaedb/issues)
 [![Slack](https://badgen.net/badge/Slack/Join%20CeresDB/0abd59?icon=slack)](https://join.slack.com/t/ceresdbcommunity/shared_invite/zt-1dcbv8yq8-Fv8aVUb6ODTL7kxbzs9fnA)
 [![Docker](https://img.shields.io/docker/v/ceresdb/ceresdb-server?logo=docker)](https://hub.docker.com/r/ceresdb/ceresdb-server)
 
 [English](./README.md)
 
-CeresDB 是一款高性能、分布式的云原生时序数据库。
+HoraeDB 是一款高性能、分布式的云原生时序数据库。
 
 ## RoadMap
-项目 [Roadmap](https://docs.ceresdb.io/dev/roadmap.html)。
+项目 [Roadmap](https://ceresdb.github.io/docs/dev/roadmap.html)。
 
 ## 快速开始
 ### 获取代码
 通过 git 克隆代码仓库并进入代码目录：
 ```bash
-git clone git@github.com:CeresDB/ceresdb.git
-cd ceresdb
+git clone git@github.com:CeresDB/horaedb.git
+cd horaedb
 ```
 
 ### 通过 Docker 运行
 确保开发环境安装了 docker，通过仓库中的提供的 Dockerfile 进行镜像的构建：
 ```shell
-docker build -t ceresdb .
+docker build -t horaedb .
 ```
 
 使用编译好的镜像，启动服务：
 ```shell
-docker run -d -t --name ceresdb -p 5440:5440 -p 8831:8831 ceresdb
+docker run -d -t --name horaedb -p 5440:5440 -p 8831:8831 horaedb
 ```
 
 ### 通过源码编译运行
 #### 安装依赖
-目前为了编译 CeresDB，需要安装相关依赖，以及 Rust 工具链。
+目前为了编译 HoraeDB，需要安装相关依赖，以及 Rust 工具链。
 
 #### 开发依赖（Ubuntu20.04）
 开发环境这里以 Ubuntu20.04 为例，执行如下的命令，即可安装好所需的依赖：
@@ -58,7 +58,7 @@ brew install cmake
 ```
 
 #### Rust
-Rust 的安装建议通过 [rustup](https://rustup.rs/)，安装了 rustup 之后，进入到 CeresDB 项目的时候，会自动根据 rust-toolchain 文件下载指定的 Rust 版本。
+Rust 的安装建议通过 [rustup](https://rustup.rs/)，安装了 rustup 之后，进入到 HoraeDB 项目的时候，会自动根据 rust-toolchain 文件下载指定的 Rust 版本。
 
 理论上执行了之后，需要添加环境变量，才能使用 Rust 工具链，一般会把下面的命令放入到自己的 `~/.bashrc` 或者 `~/.bash_profile` 中：
 ```bash
@@ -77,7 +77,7 @@ cargo build --release
 ```
 
 ### 进行数据读写
-CeresDB 支持自定义扩展的 SQL 协议，目前可以通过 http 服务以 SQL 语句进行数据的读写、表的创建。
+HoraeDB 支持自定义扩展的 SQL 协议，目前可以通过 http 服务以 SQL 语句进行数据的读写、表的创建。
 #### 建表
 ```shell
 curl --location --request POST 'http://127.0.0.1:5440/sql' \
@@ -130,29 +130,29 @@ curl --location --request POST 'http://127.0.0.1:5440/sql' \
 | x86_64-unknown-linux-gnu |    kernel 4.9+    |       构建及运行        |
 |    x86_64-apple-darwin   | 10.15+, Catalina+ |          构建          |
 |    aarch64-apple-darwin  |   11+, Big Sur+   |          构建          |
-| aarch64-unknown-linux-gnu|        TBD        | 详见 [#63](https://github.com/CeresDB/ceresdb/issues/63)|
+| aarch64-unknown-linux-gnu|        TBD        | 详见 [#63](https://github.com/CeresDB/horaedb/issues/63)|
 |         windows          |         *         |         未支持         |
 
 ## 如何贡献
-[如何参与 CeresDB 代码贡献](CONTRIBUTING.md)
+[如何参与 HoraeDB 代码贡献](CONTRIBUTING.md)
 
-[约定式提交](https://docs.ceresdb.io/cn/dev/conventional_commit)
+[约定式提交](https://ceresdb.github.io/docs/cn/dev/conventional_commit)
 
 ## 架构及技术文档
-相关技术文档请参考[docs](https://docs.ceresdb.io/)。
+相关技术文档请参考[docs](https://ceresdb.github.io/docs)。
 
 ## 致谢
-在开发 CeresDB 的过程中， 我们受到很多开源项目的影响和启发，例如  [influxdb_iox](https://github.com/influxdata/influxdb_iox), [tikv](https://github.com/tikv/tikv) 等等。感谢这些杰出的项目。
+在开发 HoraeDB 的过程中， 我们受到很多开源项目的影响和启发，例如  [influxdb_iox](https://github.com/influxdata/influxdb_iox), [tikv](https://github.com/tikv/tikv) 等等。感谢这些杰出的项目。
 
 在生产环境中，我们重度使用 [OceanBase](https://github.com/oceanbase/oceanbase) 作为 WAL 和 ObjectStore 的实现，而且 OceanBase 团队还帮助我们一起维护集群的稳定，感谢 OceanBase 团队一直以来的帮助。
 
 ## 开源许可
-CeresDB 基于 [Apache License 2.0](./LICENSE) 协议。
+HoraeDB 基于 [Apache License 2.0](./LICENSE) 协议。
 
 ## 社区
-- [CeresDB 社区角色](docs/community/ROLES-CN.md)
+- [HoraeDB 社区角色](docs/community/ROLES-CN.md)
 - [Slack](https://join.slack.com/t/ceresdbcommunity/shared_invite/zt-1dcbv8yq8-Fv8aVUb6ODTL7kxbzs9fnA)
 - 邮箱: ceresdbservice@gmail.com
 - [官方微信公众号](https://github.com/CeresDB/community/blob/main/communication/wechat/official-account-qrcode.jpg)
 - [官方微信群](https://github.com/CeresDB/community/blob/main/communication/wechat/group_qrcode.png)
-- 钉钉群: CeresDB 开源: 44602802
+- 钉钉群: HoraeDB 开源: 44602802

README.md

@@ -1,32 +1,32 @@
-![CeresDB](docs/logo/CeresDB.png)
+![HoraeDB](docs/logo/CeresDB.png)
 
 ![License](https://img.shields.io/badge/license-Apache--2.0-green.svg)
-[![CI](https://github.com/CeresDB/ceresdb/actions/workflows/ci.yml/badge.svg)](https://github.com/CeresDB/ceresdb/actions/workflows/ci.yml)
-[![OpenIssue](https://img.shields.io/github/issues/CeresDB/ceresdb)](https://github.com/CeresDB/ceresdb/issues)
+[![CI](https://github.com/CeresDB/horaedb/actions/workflows/ci.yml/badge.svg)](https://github.com/CeresDB/horaedb/actions/workflows/ci.yml)
+[![OpenIssue](https://img.shields.io/github/issues/CeresDB/horaedb)](https://github.com/CeresDB/horaedb/issues)
 [![Slack](https://badgen.net/badge/Slack/Join%20CeresDB/0abd59?icon=slack)](https://join.slack.com/t/ceresdbcommunity/shared_invite/zt-1dcbv8yq8-Fv8aVUb6ODTL7kxbzs9fnA)
 [![Docker](https://img.shields.io/docker/v/ceresdb/ceresdb-server?logo=docker)](https://hub.docker.com/r/ceresdb/ceresdb-server)
 
 [中文](./README-CN.md)
 
-CeresDB is a high-performance, distributed, cloud native time-series database.
+HoraeDB is a high-performance, distributed, cloud native time-series database.
 
 ## Documentation
-- [User Guide](https://docs.ceresdb.io/)
-- [Development Guide](https://docs.ceresdb.io/dev/compile_run.html)
-- [Roadmap](https://docs.ceresdb.io/dev/roadmap.html)
+- [User Guide](https://ceresdb.github.io/docs)
+- [Development Guide](https://ceresdb.github.io/docs/dev/compile_run.html)
+- [Roadmap](https://ceresdb.github.io/docs/dev/roadmap.html)
 
 ## Contributing
 Any contribution is welcome!
 
 Read our [Contributing Guide](CONTRIBUTING.md) and make your first contribution!
 
 ## Acknowledgment
-When develop CeresDB, we benefit a lot from several other open source projects,  such as [influxdb_iox](https://github.com/influxdata/influxdb_iox), [tikv](https://github.com/tikv/tikv) etc, thanks for their awesome work.
+When develop HoraeDB, we benefit a lot from several other open source projects,  such as [influxdb_iox](https://github.com/influxdata/influxdb_iox), [tikv](https://github.com/tikv/tikv) etc, thanks for their awesome work.
 
 In our production usage, we heavily use [OceanBase](https://github.com/oceanbase/oceanbase) as implementation of both WAL and ObjectStorage, and OceanBase team help us maintain stability of our cluster, thanks for their kindly support.
 
 ## License
-CeresDB is under [Apache License 2.0](./LICENSE).
+HoraeDB is under [Apache License 2.0](./LICENSE).
 
 ## Community and support
 - Check our community [roles](docs/community/ROLES.md)

analytic_engine/src/instance/alter.rs

@@ -146,6 +146,7 @@ impl<'a> Alterer<'a> {
             MetaEditRequest {
                 shard_info: self.table_data.shard_info,
                 meta_edit: MetaEdit::Update(meta_update),
+                table_catalog_info: self.table_data.table_catalog_info.clone(),
             }
         };
         self.instance
@@ -279,6 +280,7 @@ impl<'a> Alterer<'a> {
             MetaEditRequest {
                 shard_info: self.table_data.shard_info,
                 meta_edit: MetaEdit::Update(meta_update),
+                table_catalog_info: self.table_data.table_catalog_info.clone(),
             }
         };
         self.instance

analytic_engine/src/instance/close.rs

@@ -66,6 +66,7 @@ impl Closer {
             space_id: self.space.id,
             table_id: table_data.id,
             shard_id: table_data.shard_info.shard_id,
+            table_catalog_info: table_data.table_catalog_info.clone(),
         };
         self.manifest
             .do_snapshot(snapshot_request)

analytic_engine/src/instance/create.rs

@@ -32,7 +32,7 @@ use crate::{
     },
     manifest::meta_edit::{AddTableMeta, MetaEdit, MetaEditRequest, MetaUpdate},
     space::SpaceRef,
-    table::data::{TableDataRef, TableShardInfo},
+    table::data::{TableCatalogInfo, TableDataRef, TableShardInfo},
     table_options, TableOptions,
 };
 
@@ -96,6 +96,11 @@ impl Instance {
             MetaEditRequest {
                 shard_info: TableShardInfo::new(request.shard_id),
                 meta_edit: MetaEdit::Update(meta_update),
+                table_catalog_info: TableCatalogInfo {
+                    schema_id: request.schema_id,
+                    schema_name: request.params.schema_name,
+                    catalog_name: request.params.catalog_name,
+                },
             }
         };
         self.space_store

analytic_engine/src/instance/drop.rs

@@ -26,6 +26,7 @@ use crate::{
     },
     manifest::meta_edit::{DropTableMeta, MetaEdit, MetaEditRequest, MetaUpdate},
     space::SpaceRef,
+    table::data::TableCatalogInfo,
 };
 
 pub(crate) struct Dropper {
@@ -84,6 +85,11 @@ impl Dropper {
             MetaEditRequest {
                 shard_info: table_data.shard_info,
                 meta_edit: MetaEdit::Update(meta_update),
+                table_catalog_info: TableCatalogInfo {
+                    schema_id: request.schema_id,
+                    schema_name: request.schema_name,
+                    catalog_name: request.catalog_name,
+                },
             }
         };
         self.space_store