feat: filter out MySQL federated components' emitted statements

Cargo.toml

@@ -108,6 +108,7 @@ horaedb-client = "1.0.2"
 common_types = { path = "common_types" }
 datafusion = { git = "https://github.com/CeresDB/arrow-datafusion.git", rev = "9c3a537e25e5ab3299922864034f67fb2f79805d" }
 datafusion-proto = { git = "https://github.com/CeresDB/arrow-datafusion.git", rev = "9c3a537e25e5ab3299922864034f67fb2f79805d" }
+derive_builder = "0.12"
 df_operator = { path = "df_operator" }
 df_engine_extensions = { path = "df_engine_extensions" }
 future_ext = { path = "components/future_ext" }
@@ -135,6 +136,7 @@ meta_client = { path = "meta_client" }
 metric_ext = { path = "components/metric_ext" }
 notifier = { path = "components/notifier" }
 object_store = { path = "components/object_store" }
+once_cell = "1.18"
 panic_ext = { path = "components/panic_ext" }
 partitioned_lock = { path = "components/partitioned_lock" }
 partition_table_engine = { path = "partition_table_engine" }
@@ -152,6 +154,7 @@ proxy = { path = "proxy" }
 query_engine = { path = "query_engine" }
 query_frontend = { path = "query_frontend" }
 rand = "0.7"
+regex = "1"
 remote_engine_client = { path = "remote_engine_client" }
 reqwest = { version = "0.11", default-features = false, features = [
     "rustls-tls",
@@ -184,11 +187,10 @@ trace_metric_derive = { path = "components/trace_metric_derive" }
 trace_metric_derive_tests = { path = "components/trace_metric_derive_tests" }
 tonic = "0.8.1"
 tokio = { version = "1.29", features = ["full"] }
+uuid = "1.6.1"
 wal = { path = "src/wal" }
 xorfilter-rs = { git = "https://github.com/CeresDB/xorfilter", rev = "ac8ef01" }
 zstd = { version = "0.12", default-features = false }
-uuid = "1.6.1"
-regex = "1"
 
 # This profile optimizes for good runtime performance.
 [profile.release]

scripts/license-header.txt

@@ -1,16 +1,16 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-#   http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied.  See the License for the
-# specific language governing permissions and limitations
-# under the License.
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements.  See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership.  The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License.  You may obtain a copy of the License at
+
+  http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied.  See the License for the
+specific language governing permissions and limitations
+under the License.

server/Cargo.toml

@@ -32,6 +32,7 @@ workspace = true
 
 [dependencies]
 analytic_engine = { workspace = true }
+arc-swap = "1.5"
 arrow = { workspace = true }
 arrow_ext = { workspace = true }
 async-trait = { workspace = true }
@@ -41,6 +42,7 @@ clru = { workspace = true }
 cluster = { workspace = true }
 common_types = { workspace = true }
 datafusion = { workspace = true }
+derive_builder = { workspace = true }
 df_operator = { workspace = true }
 flate2 = "1.0"
 future_ext = { workspace = true }
@@ -55,6 +57,7 @@ logger = { workspace = true }
 macros = { workspace = true }
 meta_client = { workspace = true }
 notifier = { workspace = true }
+once_cell = { workspace = true }
 opensrv-mysql = "0.1.0"
 partition_table_engine = { workspace = true }
 paste = { workspace = true }
@@ -67,6 +70,7 @@ prost = { workspace = true }
 proxy = { workspace = true }
 query_engine = { workspace = true }
 query_frontend = { workspace = true }
+regex = { workspace = true }
 remote_engine_client = { workspace = true }
 router = { workspace = true }
 runtime = { workspace = true }