[IOTDB-3227] UDF Management in MPP Cluster: CREATE FUNCTION (#6014)
authorSteve Yurong Su <rong@apache.org>
Thu, 26 May 2022 02:28:59 +0000 (10:28 +0800)
committerGitHub <noreply@github.com>
Thu, 26 May 2022 02:28:59 +0000 (10:28 +0800)
commitd7d69709f11f3293a9a2da109c29fe89eb0ff041
tree3486f18435dabb8c5b79ad9b86c3cee5cc7fd951
parentc36df17ac358af989f86489ca97f63c32b68c6d6
[IOTDB-3227] UDF Management in MPP Cluster: CREATE FUNCTION (#6014)

New Syntax: CREATE FUNCTION AS function-name USING uris
36 files changed:
antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4
confignode/src/assembly/resources/conf/iotdb-confignode.properties
confignode/src/main/java/org/apache/iotdb/confignode/client/AsyncDataNodeClientPool.java
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/CreateFunctionHandler.java [new file with mode: 0644]
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConf.java
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeDescriptor.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigRequest.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigRequestType.java
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateFunctionReq.java [new file with mode: 0644]
confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java [new file with mode: 0644]
confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java [new file with mode: 0644]
confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigRequestExecutor.java
confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
node-commons/src/main/java/org/apache/iotdb/commons/conf/IoTDBConstant.java
node-commons/src/main/java/org/apache/iotdb/commons/service/ServiceType.java
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/SnapshotUtils.java [new file with mode: 0644]
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFClassLoaderManager.java
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableManager.java [new file with mode: 0644]
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableResource.java [new file with mode: 0644]
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFLogWriter.java
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFRegistrationInformation.java
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFRegistrationService.java
server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigTaskVisitor.java
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/CreateFunctionTask.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/ASTVisitor.java
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CreateFunctionStatement.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/service/DataNode.java
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InternalServiceImpl.java
thrift-confignode/src/main/thrift/confignode.thrift
thrift/src/main/thrift/mpp.thrift