This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira3512
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 54f960599c Merge branch 'master' of github.com:Apache/iotdb into
jira3512
add a352d93492 [IOTDB-3299] Migrate udf api to a seperate module (#6268)
add e269bb7a83 Accelerate New Cluster IT (#6326)
add 1309eef2b1 [IOTDB-3388] Let MQTT Service could parse JSON array of
existed format (#6154)
add 77563a6273 [IOTDB-3511] Show Region tool (#6315)
add e34850cacc [IOTDB-3189] Fix compaction is not well-distributed across
sgs (#6324)
add de0b507523 [IOTDB-2179] New IT framework supports Windows platform
(#6313)
add 98b65a1ba4 Fix Dead Lock Bug (#6331)
add 05a849184e [IOTDB-3365] Add more log name in query processing and Fix
NPE while fetchFragmentInstanceState (#6332)
add 6702808c25 [IOTDB-3414] [mpp] fix schema query limit offset bug (#6179)
add ed20fccc2b [IOTDB-3392] File doesn't exist when move tsfile when
virtual_storage_group_num > 1 (#6310)
add 01ca61808e Merge branch 'master' of github.com:Apache/iotdb into
jira3512
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 17 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 7 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../src/assembly/resources/conf/confignode-env.bat | 8 +-
confignode/src/assembly/resources/conf/logback.xml | 13 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 6 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +
.../consensus/request/ConfigRequest.java | 4 +
.../consensus/request/ConfigRequestType.java | 3 +-
.../GetRegionLocationsReq.java} | 29 ++--
...ssionInfoResp.java => RegionLocationsResp.java} | 29 ++--
.../iotdb/confignode/manager/ConfigManager.java | 14 ++
.../apache/iotdb/confignode/manager/Manager.java | 4 +
.../iotdb/confignode/manager/PartitionManager.java | 5 +
.../executor/ConfigRequestExecutor.java | 3 +
.../persistence/partition/PartitionInfo.java | 25 +++
.../partition/StorageGroupPartitionTable.java | 39 +++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 15 ++
.../consensus/request/ConfigRequestSerDeTest.java | 11 ++
.../confignode/persistence/PartitionInfoTest.java | 68 +++++++-
docs/UserGuide/API/Programming-MQTT.md | 7 +-
.../Maintenance-Tools/Maintenance-Command.md | 67 +++++++-
docs/zh/UserGuide/API/Programming-MQTT.md | 7 +-
.../Maintenance-Tools/Maintenance-Command.md | 63 +++++++
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 7 +
.../java/org/apache/iotdb/udf/UDTFExample.java | 22 ++-
.../iotdb/db/query/udf/example/Accumulator.java | 28 +--
.../apache/iotdb/db/query/udf/example/Adder.java | 26 ++-
.../apache/iotdb/db/query/udf/example/Counter.java | 22 +--
.../org/apache/iotdb/db/query/udf/example/Max.java | 22 ++-
.../iotdb/db/query/udf/example/Multiplier.java | 22 ++-
.../SlidingSizeWindowConstructorTester0.java | 16 +-
.../SlidingSizeWindowConstructorTester1.java | 22 ++-
.../SlidingTimeWindowConstructionTester.java | 22 +--
.../db/query/udf/example/TerminateTester.java | 18 +-
.../iotdb/db/query/udf/example/ValidateTester.java | 20 +--
.../iotdb/db/query/udf/example/WindowStartEnd.java | 18 +-
.../java/org/apache/iotdb/it/env/Cluster1Env.java | 4 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 165 ++++++++++++------
.../org/apache/iotdb/it/env/ClusterNodeBase.java | 188 ++++++++++++++-------
.../java/org/apache/iotdb/it/env/ConfigNode.java | 149 ++++++++--------
.../java/org/apache/iotdb/it/env/DataNode.java | 128 ++++++--------
.../iotdb/itbase/runtime/ClusterTestStatement.java | 42 +++--
.../itbase/runtime/ParallelRequestDelegate.java | 2 +-
...gregationWithoutValueFilterWithDeletion2IT.java | 3 +
...ggregationWithoutValueFilterWithDeletionIT.java | 3 +
...upByQueryWithoutValueFilterWithDeletion2IT.java | 3 +
...oupByQueryWithoutValueFilterWithDeletionIT.java | 3 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 5 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 3 +
integration/checkstyle.xml | 2 +-
.../iotdb/db/query/udf/example/Accumulator.java | 28 +--
.../apache/iotdb/db/query/udf/example/Adder.java | 26 ++-
.../apache/iotdb/db/query/udf/example/Counter.java | 22 +--
.../org/apache/iotdb/db/query/udf/example/Max.java | 22 ++-
.../iotdb/db/query/udf/example/Multiplier.java | 22 ++-
.../SlidingSizeWindowConstructorTester0.java | 16 +-
.../SlidingSizeWindowConstructorTester1.java | 22 ++-
.../SlidingTimeWindowConstructionTester.java | 22 +--
.../db/query/udf/example/TerminateTester.java | 18 +-
.../iotdb/db/query/udf/example/ValidateTester.java | 20 +--
.../iotdb/db/query/udf/example/WindowStartEnd.java | 18 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 8 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 138 +++++++++++++++
.../org/apache/iotdb/library/anomaly/UDTFIQR.java | 23 ++-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 21 +--
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 23 ++-
.../iotdb/library/anomaly/UDTFMissDetect.java | 21 ++-
.../apache/iotdb/library/anomaly/UDTFRange.java | 21 +--
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 21 +--
.../iotdb/library/anomaly/util/MissDetector.java | 4 +-
.../iotdb/library/anomaly/util/WindowDetect.java | 4 +-
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 26 ++-
.../org/apache/iotdb/library/dmatch/UDAFDtw.java | 26 ++-
.../apache/iotdb/library/dmatch/UDAFPearson.java | 26 ++-
.../apache/iotdb/library/dmatch/UDTFPtnSym.java | 23 ++-
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 24 ++-
.../iotdb/library/dprofile/UDAFIntegral.java | 20 +--
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 23 ++-
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 28 +--
.../apache/iotdb/library/dprofile/UDAFMedian.java | 28 +--
.../apache/iotdb/library/dprofile/UDAFMode.java | 17 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 25 +--
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 25 ++-
.../apache/iotdb/library/dprofile/UDAFSkew.java | 23 ++-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 25 +--
.../apache/iotdb/library/dprofile/UDAFStddev.java | 23 ++-
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 23 ++-
.../iotdb/library/dprofile/UDTFDistinct.java | 26 ++-
.../iotdb/library/dprofile/UDTFHistogram.java | 23 ++-
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 23 ++-
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 25 ++-
.../apache/iotdb/library/dprofile/UDTFPACF.java | 23 ++-
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 23 ++-
.../iotdb/library/dprofile/UDTFResample.java | 23 ++-
.../apache/iotdb/library/dprofile/UDTFSample.java | 23 +--
.../apache/iotdb/library/dprofile/UDTFSegment.java | 23 ++-
.../apache/iotdb/library/dprofile/UDTFSpline.java | 23 ++-
.../apache/iotdb/library/dprofile/UDTFZScore.java | 23 ++-
.../dprofile/util/ExactOrderStatistics.java | 41 ++++-
.../iotdb/library/dquality/UDTFCompleteness.java | 18 +-
.../iotdb/library/dquality/UDTFConsistency.java | 18 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 18 +-
.../iotdb/library/dquality/UDTFValidity.java | 18 +-
.../library/dquality/util/TimeSeriesQuality.java | 4 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 19 +--
.../iotdb/library/drepair/UDTFValueFill.java | 19 +--
.../iotdb/library/drepair/UDTFValueRepair.java | 19 +--
.../apache/iotdb/library/drepair/util/ARFill.java | 4 +-
.../iotdb/library/drepair/util/LikelihoodFill.java | 2 +-
.../iotdb/library/drepair/util/LinearFill.java | 2 +-
.../iotdb/library/drepair/util/LsGreedy.java | 2 +-
.../apache/iotdb/library/drepair/util/MAFill.java | 2 +-
.../iotdb/library/drepair/util/MeanFill.java | 2 +-
.../iotdb/library/drepair/util/PreviousFill.java | 2 +-
.../apache/iotdb/library/drepair/util/Screen.java | 2 +-
.../iotdb/library/drepair/util/ScreenFill.java | 4 +-
.../library/drepair/util/TimestampRepair.java | 4 +-
.../iotdb/library/drepair/util/ValueFill.java | 6 +-
.../iotdb/library/drepair/util/ValueRepair.java | 4 +-
.../apache/iotdb/library/frequency/UDTFConv.java | 26 ++-
.../apache/iotdb/library/frequency/UDTFDWT.java | 23 ++-
.../apache/iotdb/library/frequency/UDTFDeconv.java | 26 ++-
.../apache/iotdb/library/frequency/UDTFFFT.java | 23 ++-
.../iotdb/library/frequency/UDTFHighPass.java | 23 ++-
.../apache/iotdb/library/frequency/UDTFIDWT.java | 23 ++-
.../apache/iotdb/library/frequency/UDTFIFFT.java | 23 ++-
.../iotdb/library/frequency/UDTFLowPass.java | 23 ++-
.../iotdb/library/frequency/util/FFTUtil.java | 2 +-
.../library/series/UDTFConsecutiveSequences.java | 20 +--
.../library/series/UDTFConsecutiveWindows.java | 20 +--
.../iotdb/library/series/util/ConsecutiveUtil.java | 4 +-
.../iotdb/library/string/UDTFRegexMatch.java | 22 ++-
.../iotdb/library/string/UDTFRegexReplace.java | 22 ++-
.../iotdb/library/string/UDTFRegexSplit.java | 22 +--
.../iotdb/library/string/UDTFStrReplace.java | 22 ++-
.../iotdb/library/util/LinearRegression.java | 2 +-
.../java/org/apache/iotdb/library/util/Util.java | 4 +-
node-commons/pom.xml | 5 +
.../cluster/{NodeStatus.java => RegionStatus.java} | 11 +-
.../commons/udf/builtin/String/UDTFConcat.java | 22 ++-
.../commons/udf/builtin/String/UDTFEndsWith.java | 22 ++-
.../commons/udf/builtin/String/UDTFLower.java | 22 ++-
.../commons/udf/builtin/String/UDTFStartsWith.java | 22 ++-
.../commons/udf/builtin/String/UDTFStrCompare.java | 24 ++-
.../commons/udf/builtin/String/UDTFStrLength.java | 22 ++-
.../commons/udf/builtin/String/UDTFStrLocate.java | 22 ++-
.../commons/udf/builtin/String/UDTFSubstr.java | 22 ++-
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 22 ++-
.../commons/udf/builtin/String/UDTFUpper.java | 22 ++-
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 28 +--
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 17 +-
.../apache/iotdb/commons/udf/builtin/UDTFCast.java | 28 +--
.../commons/udf/builtin/UDTFCommonDerivative.java | 16 +-
.../udf/builtin/UDTFCommonValueDifference.java | 16 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 24 +--
.../iotdb/commons/udf/builtin/UDTFConstE.java | 18 +-
.../iotdb/commons/udf/builtin/UDTFConstPi.java | 18 +-
.../iotdb/commons/udf/builtin/UDTFContains.java | 24 ++-
.../udf/builtin/UDTFContinuouslySatisfy.java | 47 +++---
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 21 ++-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 29 ++--
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 28 +--
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 32 ++--
.../builtin/UDTFEqualSizeBucketRandomSample.java | 26 +--
.../udf/builtin/UDTFEqualSizeBucketSample.java | 14 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 36 ++--
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 64 ++++---
.../iotdb/commons/udf/builtin/UDTFMatches.java | 24 ++-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 36 ++--
.../udf/builtin/UDTFNonNegativeDerivative.java | 16 +-
.../builtin/UDTFNonNegativeValueDifference.java | 16 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 35 ++--
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 58 +++----
.../commons/udf/builtin/UDTFTimeDifference.java | 18 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 17 +-
.../commons/udf/builtin/UDTFValueDifference.java | 19 ++-
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 24 ++-
.../udf/service/UDFRegistrationInformation.java | 2 +-
.../udf/service/UDFRegistrationService.java | 4 +-
.../commons/udf/utils/UDFBinaryTransformer.java | 30 ++--
.../commons/udf/utils/UDFDataTypeTransformer.java | 77 +++++++++
pom.xml | 1 +
server/src/assembly/resources/conf/iotdb-env.bat | 8 +-
server/src/assembly/resources/conf/logback.xml | 13 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 28 +++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 73 +++++++-
.../db/engine/compaction/CompactionScheduler.java | 6 +-
.../DefaultCompactionTaskComparatorImpl.java | 17 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 6 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 6 +-
.../compaction/task/AbstractCompactionTask.java | 9 +-
.../db/engine/storagegroup/TsFileManager.java | 6 +
.../dataregion/StorageGroupManager.java | 19 ++-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 24 +++
.../execution/datatransfer/LocalSinkHandle.java | 72 +++++---
.../execution/datatransfer/LocalSourceHandle.java | 41 +++--
.../execution/datatransfer/SharedTsBlockQueue.java | 23 ++-
.../execution/fragment/FragmentInstanceState.java | 4 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 53 +++++-
.../plan/execution/config/ConfigTaskVisitor.java | 6 +
.../mpp/plan/execution/config/ShowRegionTask.java | 86 ++++++++++
.../config/executor/ClusterConfigTaskExecutor.java | 35 ++--
.../config/executor/IConfigTaskExecutor.java | 3 +
.../executor/StandaloneConfigTaskExecutor.java | 14 +-
.../plan/expression/multi/FunctionExpression.java | 5 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 18 ++
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 72 ++++++--
.../plan/planner/distribution/SourceRewriter.java | 7 +-
.../scheduler/AbstractFragInsStateTracker.java | 1 -
.../scheduler/FixedRateFragInsStateTracker.java | 5 +-
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 1 -
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
...ionsStatement.java => ShowRegionStatement.java} | 26 ++-
.../db/mpp/transformation/api/LayerRowReader.java | 2 +-
.../transformation/api/LayerRowWindowReader.java | 2 +-
...ializableRowRecordListBackedMultiColumnRow.java | 16 +-
...izableRowRecordListBackedMultiColumnWindow.java | 12 +-
...wRecordListBackedMultiColumnWindowIterator.java | 4 +-
...ticSerializableTVListBackedSingleColumnRow.java | 14 +-
...SerializableTVListBackedSingleColumnWindow.java | 13 +-
...ableTVListBackedSingleColumnWindowIterator.java | 4 +-
.../LayerPointReaderBackedSingleColumnRow.java | 14 +-
.../intermediate/ConstantIntermediateLayer.java | 4 +-
.../dag/intermediate/IntermediateLayer.java | 6 +-
.../MultiInputColumnIntermediateLayer.java | 8 +-
...InputColumnMultiReferenceIntermediateLayer.java | 8 +-
...nputColumnSingleReferenceIntermediateLayer.java | 8 +-
.../dag/transformer/multi/UDFQueryTransformer.java | 5 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 24 +--
.../transformation/dag/udf/UDTFTypeInferrer.java | 17 +-
.../transformation/dag/util/LayerCacheUtils.java | 5 +-
.../tv/ElasticSerializableBinaryTVList.java | 15 +-
.../tv/ElasticSerializableTVList.java | 27 ++-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 15 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../service/thrift/impl/InternalServiceImpl.java | 55 +++---
.../compaction/CompactionTaskComparatorTest.java | 74 ++++++--
.../compaction/CompactionTaskManagerTest.java | 27 ++-
.../compaction/cross/CrossSpaceCompactionTest.java | 9 +-
.../cross/RewriteCrossSpaceCompactionTest.java | 12 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 3 +-
.../db/engine/storagegroup/DataRegionTest.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 3 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 16 +-
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 58 +++++++
.../ElasticSerializableTVListTest.java | 6 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 26 ++-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
thrift-commons/src/main/thrift/common.thrift | 10 ++
.../src/main/thrift/confignode.thrift | 14 ++
.../tsfile/file/metadata/enums/TSDataType.java | 6 +-
{external-pipe-api => udf-api}/pom.xml | 6 +-
.../main/java/org/apache/iotdb}/udf/api/UDF.java | 8 +-
.../main/java/org/apache/iotdb}/udf/api/UDTF.java | 20 +--
.../java/org/apache/iotdb}/udf/api/access/Row.java | 8 +-
.../apache/iotdb}/udf/api/access/RowIterator.java | 2 +-
.../apache/iotdb}/udf/api/access/RowWindow.java | 10 +-
.../iotdb}/udf/api/collector/PointCollector.java | 56 +++---
.../api/customizer/config/UDFConfigurations.java | 8 +-
.../api/customizer/config/UDTFConfigurations.java | 24 +--
.../parameter/UDFParameterValidator.java | 47 +++---
.../api/customizer/parameter/UDFParameters.java | 29 ++--
.../api/customizer/strategy/AccessStrategy.java | 8 +-
.../strategy/RowByRowAccessStrategy.java | 12 +-
.../strategy/SlidingSizeWindowAccessStrategy.java | 12 +-
.../strategy/SlidingTimeWindowAccessStrategy.java | 12 +-
.../UDFAttributeNotProvidedException.java | 2 +-
.../iotdb}/udf/api/exception/UDFException.java | 2 +-
.../UDFInputSeriesDataTypeNotValidException.java | 10 +-
.../UDFInputSeriesIndexNotValidException.java | 2 +-
.../UDFInputSeriesNumberNotValidException.java | 2 +-
.../UDFOutputSeriesDataTypeNotValidException.java | 2 +-
.../exception/UDFParameterNotValidException.java | 2 +-
.../api/exception/UDFRegistrationException.java | 2 +-
.../org/apache/iotdb/udf/api/type}/Binary.java | 57 +++++--
.../java/org/apache/iotdb/udf/api/type/Type.java | 39 +++--
279 files changed, 3570 insertions(+), 2284 deletions(-)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/DropFunctionReq.java
=> read/GetRegionLocationsReq.java} (63%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{PermissionInfoResp.java
=> RegionLocationsResp.java} (68%)
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsfileWithVirtualSGIT.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/cluster/{NodeStatus.java =>
RegionStatus.java} (85%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/LogicalQueryPlan.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/UDFBinaryTransformer.java
(54%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowRegionTask.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{ShowFunctionsStatement.java
=> ShowRegionStatement.java} (69%)
copy {external-pipe-api => udf-api}/pom.xml (87%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/UDF.java (83%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/UDTF.java (86%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/access/Row.java (95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/access/RowIterator.java (96%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/access/RowWindow.java (91%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/collector/PointCollector.java
(75%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/config/UDFConfigurations.java
(83%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/config/UDTFConfigurations.java
(78%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/parameter/UDFParameterValidator.java
(81%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/parameter/UDFParameters.java
(81%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/AccessStrategy.java
(85%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/RowByRowAccessStrategy.java
(83%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/SlidingSizeWindowAccessStrategy.java
(91%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/customizer/strategy/SlidingTimeWindowAccessStrategy.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFAttributeNotProvidedException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java
(79%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFInputSeriesIndexNotValidException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFInputSeriesNumberNotValidException.java
(96%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFOutputSeriesDataTypeNotValidException.java
(95%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFParameterNotValidException.java
(94%)
rename {node-commons/src/main/java/org/apache/iotdb/commons =>
udf-api/src/main/java/org/apache/iotdb}/udf/api/exception/UDFRegistrationException.java
(95%)
copy {tsfile/src/main/java/org/apache/iotdb/tsfile/utils =>
udf-api/src/main/java/org/apache/iotdb/udf/api/type}/Binary.java (64%)
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricLevel.java
=> udf-api/src/main/java/org/apache/iotdb/udf/api/type/Type.java (65%)