Skip to content

Commit dae76be

Browse files
author
Liu Zhengyun
committed
add classify_tvf
1 parent fe16a22 commit dae76be

File tree

3 files changed

+406
-1
lines changed

3 files changed

+406
-1
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/TableBuiltinTableFunction.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,7 @@
2525
import org.apache.iotdb.commons.udf.builtin.relational.tvf.SessionTableFunction;
2626
import org.apache.iotdb.commons.udf.builtin.relational.tvf.TumbleTableFunction;
2727
import org.apache.iotdb.commons.udf.builtin.relational.tvf.VariationTableFunction;
28+
import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.ClassifyTableFunction;
2829
import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.ForecastTableFunction;
2930
import org.apache.iotdb.db.queryengine.plan.relational.function.tvf.PatternMatchTableFunction;
3031
import org.apache.iotdb.udf.api.relational.TableFunction;
@@ -42,7 +43,8 @@ public enum TableBuiltinTableFunction {
4243
VARIATION("variation"),
4344
CAPACITY("capacity"),
4445
FORECAST("forecast"),
45-
PATTERN_MATCH("pattern_match");
46+
PATTERN_MATCH("pattern_match"),
47+
CLASSIFY("classify");
4648

4749
private final String functionName;
4850

@@ -86,6 +88,8 @@ public static TableFunction getBuiltinTableFunction(String functionName) {
8688
return new CapacityTableFunction();
8789
case "forecast":
8890
return new ForecastTableFunction();
91+
case "classify":
92+
return new ClassifyTableFunction();
8993
default:
9094
throw new UnsupportedOperationException("Unsupported table function: " + functionName);
9195
}

0 commit comments

Comments
 (0)