iotdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sunzes...@apache.org
Subject [iotdb] branch time_index_improve updated (f5c9995 -> 85f8a9e)
Date Wed, 30 Dec 2020 06:51:40 GMT
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


Mime
View raw message