You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by su...@apache.org on 2020/12/30 06:51:40 UTC
[iotdb] branch time_index_improve updated (f5c9995 -> 85f8a9e)
This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a change to branch time_index_improve
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f5c9995 Record the device number of the last TsFile in each storage group
add 1ee1dd5 Update PartialPathTest.java (#2274)
add 1981766 remove useless coeds
add 852fbb9 Merge pull request #2302 from neuyilan/apache_master_1222_remove_useless_code
add 537aebf [IOTDB-944] Support UDTF (User-defined Timeseries Generating Function) (#1828)
add ac8c887 Update TsFileIOWriter.java (#2320)
add 21d356c Fix documents that are not linked to official websites (#2324)
add 92e26fb fix incorrect MetadataException printf info. (#2323)
add b4f41ba Remove a useless comma in the usage info of cluster (#2328)
add d76076d refactor the code
add 095803c Merge pull request #2339 from neuyilan/apache_master_1225_refactor_the_code
add 63c2aad fix wal buffer annotation (#2311)
add ec88e69 Bump maven wrapper from 3.6.1 to 3.6.3
add 231b334 Remove extra bracket to make the param annotation take effect
add 69de3d6 1. add pr template; 2. disable enforcer check in travis; 3. test sonar token
add 0b25cba supply the cluster version status code (#2342)
add 258d4ce Fix a potential overflow in udf (#2345)
add a3ea467 Fix the default value of operation timeout (#2330)
add a898e72 Delete update operation (#2288)
add 3496136 fix
add 346da56 fix fix
add 10ae899 Merge pull request #2362 from LebronAl/fix_serialToParallelPool_init_bug
add 3e24aef [IOTDB-1086] Improve document of Zeppelin installation (#2354)
add 8ffc98d [IOTDB-1090] Unable to update UDF (#2361)
add 7c2628e [IOTDB-1065] Fix deletion bug while trying to delete data from a timeseries which contains comma (#2306)
add 83e2722 fix some typo & make code more understandable (#2360)
add a71204e fix concurrent bug of mlogWriter (#2335)
add a93f3c1 Fix the spelling of DEFAULT in connection params
add 4218a96 Merge switch branchs in the authority checker
add ffab403 Use TimeUnit instead of plain number to improve readability
add bf19c0e Using system arraycopy instead of manual for loop
add 4968b7b Fix the condition of logger with the right level for merging file task
add c125df3 Fix the input resource leak when deserializing device owner (#2374)
add 4c16060 [IOTDB-1070] Add interface `terminate` for UDTF (#2366)
add 91db5fa Compaction not block flush (#2341)
add d98e150 Move coordinator from meta group member (#2334)
add ac7a928 add the trace log
add 70c8fa59 Merge pull request #2369 from neuyilan/apache_master_1229_add_trace_log
add 354abac Merge remote-tracking branch 'origin/master' into time_index_improve
add 85f8a9e Fix bug
No new revisions were added by this update.
Summary of changes:
.github/pull_request_template.md | 93 +++
.github/workflows/sonar_and_coverall.yml | 2 +-
.mvn/wrapper/maven-wrapper.properties | 2 +-
.travis.yml | 10 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 52 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 2 +-
.../cluster/client/async/AsyncClientPool.java | 1 -
.../apache/iotdb/cluster/config/ClusterConfig.java | 14 +-
.../iotdb/cluster/config/ClusterConstant.java | 6 +-
.../iotdb/cluster/coordinator/Coordinator.java | 598 ++++++++++++++++++
.../apache/iotdb/cluster/metadata/CMManager.java | 8 +-
.../cluster/query/ClusterConcatPathOptimizer.java | 4 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 10 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 9 -
.../apache/iotdb/cluster/server/ClientServer.java | 26 +-
.../iotdb/cluster/server/MetaClusterServer.java | 5 +
.../org/apache/iotdb/cluster/server/Timer.java | 13 +-
.../cluster/server/member/DataGroupMember.java | 2 +-
.../cluster/server/member/MetaGroupMember.java | 576 ++---------------
.../iotdb/cluster/server/member/RaftMember.java | 21 +-
.../cluster/server/service/BaseSyncService.java | 7 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 6 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 3 +
.../cluster/log/snapshot/DataSnapshotTest.java | 5 +
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +
.../cluster/partition/SlotPartitionTableTest.java | 14 -
.../query/ClusterPhysicalGeneratorTest.java | 10 +-
.../cluster/query/ClusterPlanExecutorTest.java | 4 +-
.../iotdb/cluster/server/member/MemberTest.java | 10 +-
.../cluster/server/member/MetaGroupMemberTest.java | 24 +-
docs/UserGuide/Client/Status Codes.md | 8 +
.../Ecosystem Integration/Zeppelin-IoTDB.md | 9 +-
.../Operation Manual/UDF User Defined Function.md | 476 ++++++++++++++
docs/zh/UserGuide/Client/Status Codes.md | 9 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 9 +-
.../Operation Manual/UDF User Defined Function.md | 476 ++++++++++++++
example/pom.xml | 1 +
example/udf/pom.xml | 82 +++
.../java/org/apache/iotdb/udf/UDTFExample.java | 56 ++
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 2 +-
.../resources/conf/iotdb-engine.properties | 24 +-
server/src/assembly/resources/conf/logback.xml | 24 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 20 +-
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 105 +++-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 5 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 43 ++
.../compaction/CompactionMergeTaskPoolManager.java | 32 +-
.../db/engine/compaction/TsFileManagement.java | 22 +-
.../level/LevelCompactionTsFileManagement.java | 190 +++---
.../no/NoCompactionTsFileManagement.java | 5 -
.../engine/compaction/utils/CompactionUtils.java | 12 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 2 +-
.../io/LocalTextModificationAccessor.java | 61 +-
.../engine/storagegroup/StorageGroupProcessor.java | 67 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 6 +-
.../UDFRegistrationException.java} | 72 +--
.../iotdb/db/metadata/logfile/MLogWriter.java | 22 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 9 +-
.../apache/iotdb/db/qp/constant/DatetimeUtils.java | 40 ++
.../apache/iotdb/db/qp/constant/SQLConstant.java | 14 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 11 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 70 ++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 3 +-
.../iotdb/db/qp/logical/crud/SFWOperator.java | 16 +-
.../iotdb/db/qp/logical/crud/SelectOperator.java | 47 +-
.../CreateFunctionOperator.java} | 99 +--
.../DropFunctionOperator.java} | 81 ++-
.../ShowFunctionsOperator.java} | 78 ++-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 52 ++
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 133 ++++
.../iotdb/db/qp/physical/crud/UpdatePlan.java | 135 ----
.../sys/{ShowPlan.java => CreateFunctionPlan.java} | 114 ++--
.../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 81 +--
.../sys/ShowFunctionsPlan.java} | 75 +--
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 152 +++--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 7 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 130 ++--
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 192 ++++--
.../db/query/aggregation/AggregateResult.java | 2 +-
.../db/query/aggregation/AggregationType.java | 1 -
.../db/query/control/QueryResourceManager.java | 6 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../dataset/DirectAlignByTimeDataSet.java} | 74 +--
.../dataset/DirectNonAlignDataSet.java} | 72 +--
.../apache/iotdb/db/query/dataset/ListDataSet.java | 4 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 28 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 4 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 24 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 4 +-
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 277 ++++++++
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 152 +++++
.../db/query/dataset/UDTFNonAlignDataSet.java | 191 ++++++
.../dataset/groupby/GroupByEngineDataSet.java | 4 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 4 +-
.../query/dataset/groupby/GroupByTimeDataSet.java | 4 +-
.../groupby/GroupByWithValueFilterDataSet.java | 2 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 2 +-
.../iotdb/db/query/executor/IQueryRouter.java | 8 +-
.../iotdb/db/query/executor/QueryRouter.java | 51 +-
.../db/query/executor/RawDataQueryExecutor.java | 22 +-
.../iotdb/db/query/executor/UDTFQueryExecutor.java | 84 +++
.../UpdateOperator.java => query/udf/api/UDF.java} | 70 +--
.../org/apache/iotdb/db/query/udf/api/UDTF.java | 113 ++++
.../apache/iotdb/db/query/udf/api/access/Row.java | 119 ++++
.../udf/api/access/RowIterator.java} | 90 +--
.../iotdb/db/query/udf/api/access/RowWindow.java | 61 ++
.../db/query/udf/api/collector/PointCollector.java | 137 ++++
.../api/customizer/config/UDFConfigurations.java} | 79 ++-
.../api/customizer/config/UDTFConfigurations.java | 105 ++++
.../api/customizer/parameter/UDFParameters.java | 119 ++++
.../api/customizer/strategy/AccessStrategy.java | 64 ++
.../strategy/RowByRowAccessStrategy.java | 61 ++
.../strategy/SlidingSizeWindowAccessStrategy.java | 123 ++++
.../strategy/SlidingTimeWindowAccessStrategy.java | 249 ++++++++
.../iotdb/db/query/udf/core/access/RowImpl.java | 93 +++
.../db/query/udf/core/access/RowIteratorImpl.java | 58 ++
.../db/query/udf/core/access/RowWindowImpl.java | 75 +++
.../db/query/udf/core/context/UDFContext.java | 134 ++++
.../db/query/udf/core/executor/UDTFExecutor.java | 105 ++++
.../iotdb/db/query/udf/core/input/InputLayer.java | 563 +++++++++++++++++
.../iotdb/db/query/udf/core/input/SafetyLine.java | 60 ++
.../udf/core/reader/LayerPointReader.java} | 89 +--
.../udf/core/reader/LayerRowReader.java} | 79 ++-
.../udf/core/reader/LayerRowWindowReader.java} | 77 ++-
.../core/transformer/RawQueryPointTransformer.java | 72 +++
.../db/query/udf/core/transformer/Transformer.java | 93 +++
.../core/transformer/UDFQueryRowTransformer.java | 84 +--
.../transformer/UDFQueryRowWindowTransformer.java | 46 ++
.../udf/core/transformer/UDFQueryTransformer.java | 101 +++
.../query/udf/datastructure/SerializableList.java | 165 +++++
.../primitive/ElasticSerializableIntList.java | 109 ++++
.../udf/datastructure/primitive/IntList.java} | 74 +--
.../primitive/SerializableIntList.java | 131 ++++
.../datastructure/primitive/WrappedIntArray.java | 90 +--
.../row/ElasticSerializableRowRecordList.java | 234 +++++++
.../row/SerializableRowRecordList.java | 245 ++++++++
.../tv/ElasticSerializableBinaryTVList.java | 121 ++++
.../tv/ElasticSerializableTVList.java | 312 +++++++++
.../datastructure/tv/SerializableBinaryTVList.java | 79 +++
.../tv/SerializableBooleanTVList.java | 69 ++
.../datastructure/tv/SerializableDoubleTVList.java | 69 ++
.../datastructure/tv/SerializableFloatTVList.java | 69 ++
.../datastructure/tv/SerializableIntTVList.java | 69 ++
.../datastructure/tv/SerializableLongTVList.java | 69 ++
.../udf/datastructure/tv/SerializableTVList.java | 99 +++
.../udf/service/TemporaryQueryDataFileService.java | 136 ++++
.../iotdb/db/query/udf/service/UDFClassLoader.java | 83 +++
.../query/udf/service/UDFClassLoaderManager.java | 122 ++++
.../iotdb/db/query/udf/service/UDFLogWriter.java | 69 ++
.../udf/service/UDFRegistrationInformation.java | 57 ++
.../query/udf/service/UDFRegistrationService.java | 339 ++++++++++
.../java/org/apache/iotdb/db/service/IoTDB.java | 10 +-
.../org/apache/iotdb/db/service/ServiceType.java | 9 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 113 ++--
.../db/sync/receiver/load/FileLoaderManager.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 25 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 9 -
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 3 -
.../compaction/LevelCompactionMergeTest.java | 4 +-
.../LevelCompactionTsFileManagementTest.java | 1 -
.../NoCompactionTsFileManagementTest.java | 1 -
.../iotdb/db/engine/storagegroup/TTLTest.java | 2 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 35 ++
.../db/integration/IoTDBLevelCompactionIT.java | 3 +
.../iotdb/db/integration/IoTDBRestartIT.java | 40 +-
.../db/integration/IoTDBRpcCompressionIT.java | 1 -
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 6 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 308 +++++++++
.../db/integration/IoTDBUDFWindowQueryIT.java | 513 +++++++++++++++
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 694 +++++++++++++++++++++
.../db/integration/IoTDBUDTFHybridQueryIT.java | 166 +++++
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 337 ++++++++++
.../apache/iotdb/db/metadata/PartialPathTest.java | 34 +-
.../iotdb/db/qp/plan/ConcatOptimizerTest.java | 7 +-
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 213 ++++++-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 578 +++++++++++++++++
.../ElasticSerializableRowRecordListTest.java | 224 +++++++
.../ElasticSerializableTVListTest.java | 251 ++++++++
.../SerializableBinaryTVListTest.java | 80 +++
.../SerializableBooleanTVListTest.java | 80 +++
.../SerializableDoubleTVListTest.java | 79 +++
.../datastructure/SerializableFloatTVListTest.java | 78 +++
.../datastructure/SerializableIntTVListTest.java | 78 +++
.../udf/datastructure/SerializableListTest.java} | 81 ++-
.../datastructure/SerializableLongTVListTest.java | 78 +++
.../SerializableRowRecordListTest.java | 143 +++++
.../udf/datastructure/SerializableTVListTest.java} | 79 ++-
.../iotdb/db/query/udf/example/Accumulator.java | 82 +++
.../apache/iotdb/db/query/udf/example/Adder.java | 78 +++
.../apache/iotdb/db/query/udf/example/Counter.java | 76 +++
.../org/apache/iotdb/db/query/udf/example/Max.java | 64 ++
.../iotdb/db/query/udf/example/Multiplier.java | 54 ++
.../SlidingSizeWindowConstructorTester0.java | 53 ++
.../SlidingSizeWindowConstructorTester1.java | 54 ++
.../SlidingTimeWindowConstructionTester.java | 61 ++
.../db/query/udf/example/TerminateTester.java | 64 ++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 8 +
.../apache/iotdb/db/writelog/PerformanceTest.java | 15 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 -
.../java/org/apache/iotdb/session/SessionUT.java | 2 +-
site/src/main/.vuepress/config.js | 26 +-
.../tsfile/encoding/bitpacking/IntPacker.java | 4 +-
.../tsfile/encoding/bitpacking/LongPacker.java | 4 +-
.../org/apache/iotdb/tsfile/read/common/Field.java | 4 -
.../apache/iotdb/tsfile/read/common/RowRecord.java | 2 +-
.../query/dataset/DataSetWithTimeGenerator.java | 4 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 4 +-
.../tsfile/read/query/dataset/EmptyDataSet.java | 4 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 4 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 11 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
218 files changed, 14702 insertions(+), 2239 deletions(-)
create mode 100644 .github/pull_request_template.md
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java
create mode 100644 docs/UserGuide/Operation Manual/UDF User Defined Function.md
create mode 100644 docs/zh/UserGuide/Operation Manual/UDF User Defined Function.md
create mode 100644 example/udf/pom.xml
create mode 100644 example/udf/src/main/java/org/apache/iotdb/udf/UDTFExample.java
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => exception/UDFRegistrationException.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/{crud/UpdateOperator.java => sys/CreateFunctionOperator.java} (51%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/{crud/UpdateOperator.java => sys/DropFunctionOperator.java} (66%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/{crud/UpdateOperator.java => sys/ShowFunctionsOperator.java} (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UDFPlan.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UDTFPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UpdatePlan.java
copy server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowPlan.java => CreateFunctionPlan.java} (60%)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterConcatPathOptimizer.java => server/src/main/java/org/apache/iotdb/db/qp/physical/sys/DropFunctionPlan.java (61%)
copy server/src/main/java/org/apache/iotdb/db/qp/{logical/crud/UpdateOperator.java => physical/sys/ShowFunctionsPlan.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/dataset/DirectAlignByTimeDataSet.java} (62%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/dataset/DirectNonAlignDataSet.java} (62%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDTFAlignByTimeDataSet.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDTFDataSet.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDTFNonAlignDataSet.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/executor/UDTFQueryExecutor.java
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/UDF.java} (65%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/UDTF.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/access/Row.java
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/access/RowIterator.java} (50%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/access/RowWindow.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/collector/PointCollector.java
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/customizer/config/UDFConfigurations.java} (60%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/config/UDTFConfigurations.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/parameter/UDFParameters.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/strategy/AccessStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/strategy/RowByRowAccessStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/strategy/SlidingSizeWindowAccessStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/strategy/SlidingTimeWindowAccessStrategy.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/access/RowImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/access/RowIteratorImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/access/RowWindowImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/context/UDFContext.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/executor/UDTFExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/input/InputLayer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/input/SafetyLine.java
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/core/reader/LayerPointReader.java} (51%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/core/reader/LayerRowReader.java} (62%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/core/reader/LayerRowWindowReader.java} (60%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/RawQueryPointTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/Transformer.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/dataset/EmptyDataSet.java => server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/UDFQueryRowTransformer.java (50%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/UDFQueryRowWindowTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/UDFQueryTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/SerializableList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/ElasticSerializableIntList.java
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/datastructure/primitive/IntList.java} (65%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/SerializableIntList.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/dataset/EmptyDataSet.java => server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/WrappedIntArray.java (62%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/row/ElasticSerializableRowRecordList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/row/SerializableRowRecordList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/ElasticSerializableBinaryTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/ElasticSerializableTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableBinaryTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableBooleanTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableDoubleTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableFloatTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableIntTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableLongTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/tv/SerializableTVList.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/service/TemporaryQueryDataFileService.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/service/UDFClassLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/service/UDFClassLoaderManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/service/UDFLogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/service/UDFRegistrationInformation.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/service/UDFRegistrationService.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFManagementIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFWindowQueryIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFHybridQueryIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFNonAlignQueryIT.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/dataset/UDTFAlignByTimeDataSetTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/ElasticSerializableRowRecordListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/ElasticSerializableTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableBinaryTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableBooleanTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableDoubleTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableFloatTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableIntTVListTest.java
copy server/src/{main/java/org/apache/iotdb/db/qp/logical/crud/UpdateOperator.java => test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableListTest.java} (55%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableLongTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableRowRecordListTest.java
rename server/src/{main/java/org/apache/iotdb/db/qp/logical/crud/UpdateOperator.java => test/java/org/apache/iotdb/db/query/udf/datastructure/SerializableTVListTest.java} (62%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/Accumulator.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/Adder.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/Counter.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/Max.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/Multiplier.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester0.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/SlidingTimeWindowConstructionTester.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java