This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a change to branch monitor_tool
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 4f3377d add shell
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 3da20a7 init
add 9d501f6 Merge branch 'master' into monitor_tool
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 | 11 +-
.../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 | 107 +++-
.../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 | 90 +--
.../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 | 18 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 13 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 124 ++--
.../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 | 5 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 152 +++--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 7 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 135 ++--
.../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 | 3 +-
.../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 ++++++++++
.../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/IoTDBRpcDataSet.java | 2 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 -
.../apache/iotdb/session/SessionConnection.java | 2 +-
.../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, 14694 insertions(+), 2302 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} (59%)
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
