This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch Wal_mem_control
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8369f9f99c4 fix concurrent issue
add 076b2538a17 add udaf PatternMatch DTWMatch (#14258) (#14340)
add a9c55474839 Pipe: add information about sender's IP and port in the
pipe receiver logs (#14343)
add 5c84e68de09 Implement alter database in table model
add 09288dac0cb [TABLE MODEL] Implement CREATE/SHOW/DROP Function and
user-defined scalar function
add 4e393b373f0 Merge branch 'master' of github.com:apache/iotdb into
Wal_mem_control
add 17fd47febbd add metric
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/udf/ScalarFunctionExample.java | 70 +
.../db/query/udf/example/relational/AllSum.java | 106 +
.../query/udf/example/relational/ContainNull.java | 52 +
.../query/udf/example/relational/DatePlusOne.java | 57 +
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 3 +
.../it/db/it/udf/IoTDBSQLFunctionManagementIT.java | 292 +
.../it/db/it/udf/scalar/IoTDBScalarFunctionIT.java | 224 +
.../iotdb/relational/it/schema/IoTDBTableIT.java | 7 +-
.../config/ScalarFunctionConfig.java} | 18 +-
.../customizer/parameter/FunctionParameters.java | 87 +
...egationFunction.java => AggregateFunction.java} | 2 +-
.../iotdb/udf/api/relational/ScalarFunction.java | 49 +-
.../iotdb/udf/api/relational/access/Record.java | 44 +-
.../iotdb/confignode/manager/UDFManager.java | 18 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 16 +
.../manager/schema/ClusterSchemaManager.java | 4 +-
.../persistence/schema/ClusterSchemaInfo.java | 9 +
.../confignode/persistence/schema/ConfigMTree.java | 3 +-
.../impl/schema/DeleteDatabaseProcedure.java | 49 +-
.../procedure/impl/schema/SchemaUtils.java | 6 +-
.../impl/schema/table/CreateTableProcedure.java | 4 +-
.../procedure/state/schema/AlterDatabaseState.java | 9 +-
.../procedure/store/ProcedureFactory.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 2 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 10 +-
.../response/ConvertToThriftRespTest.java | 32 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 18 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 12 +
.../iotdb/db/protocol/session/IClientSession.java | 2 +-
.../db/protocol/session/RestClientSession.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 8 +-
.../relational/aggregation/AccumulatorFactory.java | 4 +-
.../relational/ColumnTransformerBuilder.java | 34 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 10 +-
.../execution/config/TableConfigTaskVisitor.java | 52 +-
.../config/executor/ClusterConfigTaskExecutor.java | 55 +-
.../config/executor/IConfigTaskExecutor.java | 3 +
.../config/metadata/ShowFunctionsTask.java | 95 +-
...CreateDBTask.java => AbstractDatabaseTask.java} | 22 +-
.../{CreateDBTask.java => AlterDBTask.java} | 26 +-
.../config/metadata/relational/CreateDBTask.java | 25 +-
.../plan/planner/TableOperatorGenerator.java | 2 +-
.../relational/analyzer/ExpressionTreeUtils.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 8 +-
.../function/InterpretedFunctionInvoker.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 32 +-
.../distribute/TableDistributedPlanGenerator.java | 2 +-
.../PushAggregationIntoTableScan.java | 2 +-
.../relational/planner/optimizations/Util.java | 2 +-
.../plan/relational/sql/ast/AlterDB.java | 56 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/CreateDB.java | 77 +-
.../ast/{CreateDB.java => DatabaseStatement.java} | 62 +-
.../sql/ast/DefaultTraversalVisitor.java | 9 +
.../plan/relational/sql/parser/AstBuilder.java | 40 +-
.../relational/sql/util/ExpressionFormatter.java | 2 +-
.../plan/relational/sql/util/SqlFormatter.java | 22 +-
.../udf/UserDefineScalarFunctionTransformer.java | 108 +
.../iotdb/db/service/metrics/WritingMetrics.java | 32 +
.../db/storageengine/rescon/memory/SystemInfo.java | 1 +
.../plan/relational/analyzer/TSBSTest.java | 2 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 11 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 8 +-
.../schema/table/TsTableInternalRPCType.java | 16 +-
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../apache/iotdb/commons/udf/UDFInformation.java | 19 +-
.../java/org/apache/iotdb/commons/udf/UDFType.java | 128 +-
.../iotdb/commons/udf/access/RecordIterator.java | 119 +
.../TableBuiltinAggregationFunction.java | 10 +-
.../relational}/TableBuiltinScalarFunction.java | 17 +-
.../commons/udf/service/UDFManagementService.java | 24 +-
.../iotdb/commons/udf/utils/TableUDFUtils.java | 66 +
.../commons/udf/utils/UDFDataTypeTransformer.java | 93 +
.../org/apache/iotdb/commons/udf/UDFTypeTest.java | 81 +
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +
.../thrift-commons/src/main/thrift/common.thrift | 11 +-
.../src/main/thrift/confignode.thrift | 1 +
library-udf/src/assembly/tools/register-UDF.bat | 3 +
library-udf/src/assembly/tools/register-UDF.sh | 3 +
.../iotdb/library/match/PatternExecutor.java | 798 ++
.../iotdb/library/match/PatternMatchConfig.java | 69 +
.../apache/iotdb/library/match/UDAFDTWMatch.java | 201 +
.../iotdb/library/match/UDAFPatternMatch.java | 164 +
.../apache/iotdb/library/match/model/Bounds.java | 41 +-
.../iotdb/library/match/model/DTWMatchResult.java | 55 +
.../apache/iotdb/library/match/model/DTWState.java | 161 +
.../match/model/PatternCalculationResult.java | 25 +-
.../iotdb/library/match/model/PatternContext.java | 59 +
.../iotdb/library/match/model/PatternResult.java | 113 +
.../iotdb/library/match/model/PatternState.java | 92 +
.../apache/iotdb/library/match/model/Point.java | 91 +
.../apache/iotdb/library/match/model/Section.java | 132 +
.../library/match/model/SectionCalculation.java | 43 +-
.../iotdb/library/match/model/SectionNext.java | 36 +-
.../iotdb/library/match/utils/LinearScale.java | 46 +
.../iotdb/library/match/utils/TimeScale.java | 8 +-
.../org/apache/iotdb/library/UDAFPatternTest.java | 88 +
library-udf/src/test/resources/patternData | 8989 ++++++++++++++++++++
library-udf/src/test/resources/patternPart | 737 ++
pom.xml | 2 +-
100 files changed, 14225 insertions(+), 353 deletions(-)
create mode 100644
example/udf/src/main/java/org/apache/iotdb/udf/ScalarFunctionExample.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/AllSum.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/ContainNull.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/DatePlusOne.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/IoTDBSQLFunctionManagementIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/udf/scalar/IoTDBScalarFunctionIT.java
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/{relational/AggregationFunction.java
=> customizer/config/ScalarFunctionConfig.java} (64%)
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/customizer/parameter/FunctionParameters.java
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/{AggregationFunction.java
=> AggregateFunction.java} (93%)
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/AlterDatabaseState.java
(82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{CreateDBTask.java
=> AbstractDatabaseTask.java} (71%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{CreateDBTask.java
=> AlterDBTask.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AlterDB.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateDB.java
=> DatabaseStatement.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/udf/UserDefineScalarFunctionTransformer.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/access/RecordIterator.java
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational}/TableBuiltinAggregationFunction.java
(91%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational}/TableBuiltinScalarFunction.java
(76%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/TableUDFUtils.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/UDFTypeTest.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/PatternExecutor.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/PatternMatchConfig.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/UDAFDTWMatch.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/UDAFPatternMatch.java
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
=> library-udf/src/main/java/org/apache/iotdb/library/match/model/Bounds.java
(52%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/DTWMatchResult.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/DTWState.java
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
=>
library-udf/src/main/java/org/apache/iotdb/library/match/model/PatternCalculationResult.java
(63%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/PatternContext.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/PatternResult.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/PatternState.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/Point.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/model/Section.java
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
=>
library-udf/src/main/java/org/apache/iotdb/library/match/model/SectionCalculation.java
(52%)
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
=>
library-udf/src/main/java/org/apache/iotdb/library/match/model/SectionNext.java
(60%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/match/utils/LinearScale.java
rename
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
=>
library-udf/src/main/java/org/apache/iotdb/library/match/utils/TimeScale.java
(76%)
create mode 100644
library-udf/src/test/java/org/apache/iotdb/library/UDAFPatternTest.java
create mode 100644 library-udf/src/test/resources/patternData
create mode 100644 library-udf/src/test/resources/patternPart
