This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/mysql-connector in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7e5b6cb93596b08c04cd32acf2ca63fc17c5afde Author: JackieTien97 <[email protected]> AuthorDate: Thu Jun 5 21:18:46 2025 +0800 Support query from mysql --- .../plan/relational/function/TableBuiltinTableFunction.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/TableBuiltinTableFunction.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/TableBuiltinTableFunction.java index 4a07f9a0c7b..bd19dc636f3 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/TableBuiltinTableFunction.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/TableBuiltinTableFunction.java @@ -26,6 +26,7 @@ import org.apache.iotdb.commons.udf.builtin.relational.tvf.SessionTableFunction; import org.apache.iotdb.commons.udf.builtin.relational.tvf.TumbleTableFunction; import org.apache.iotdb.commons.udf.builtin.relational.tvf.VariationTableFunction; import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.ForecastTableFunction; +import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.connector.MySqlConnectorTableFunction; import org.apache.iotdb.udf.api.relational.TableFunction; import java.util.Arrays; @@ -40,7 +41,8 @@ public enum TableBuiltinTableFunction { SESSION("session"), VARIATION("variation"), CAPACITY("capacity"), - FORECAST("forecast"); + FORECAST("forecast"), + MYSQL_CONNECTOR("mysql_connector"); private final String functionName; @@ -82,6 +84,8 @@ public enum TableBuiltinTableFunction { return new CapacityTableFunction(); case "forecast": return new ForecastTableFunction(); + case "mysql_connector": + return new MySqlConnectorTableFunction(); default: throw new UnsupportedOperationException("Unsupported table function: " + functionName); }
