You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2021/01/04 07:07:48 UTC
[iotdb] branch NewTsFile updated (3d5f885 -> 990e3a7)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch NewTsFile
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 3d5f885 [IOTDB-1082] Update MetadataIndexTree structure for v0.12 (#2401)
add 491c17f fix TsFile doc (#2282)
add f77b851 Add Unit tests for Utils module (#2246)
add e97d532 add auth test UT (#2271)
add 413fe1b Fix the path of seed_nodes configuration (#2206)
add 113bd38 add new committer HouliangQi (#2286)
add 35fb6c0 change parallelism in timeseries metadata cache (#2289)
add 758c450 Fixed a section number in the sync tool document (#2296)
add 923cf57 add new committer Xinyu Tan (#2297)
add ebe335c Remove extra commas to make the param annotation take effect (#2295)
add b30cec2 fix some doc grammar issues in the cluster module (#2287)
add 59e9b9c add missing information of javadoc in cluster module (#2285)
add b75ceb0 Revert "using sonar secret token" (#2298)
add 2bdae11 Fix dependency bug and add documents (#2299)
add 2c88609 [IOTDB-1066] Code improvement (#2300)
add eed2a4a fix ArithmeticException (#2284)
add 740e7c9 fix client is null caluse NullException
add f51b7bf remend the async client pool comment
add 2acfd66 Merge pull request #2277 from neuyilan/apache_master_1217_fix_client_is_null
add 5d91586 add SDT docs (#2307)
add becbd87 upgrade guava version (#2303)
add bb40b81 fix a bug of cal MaxDeduplicatedPathNum (#2310)
add 5fb992f Fix sync schema bug (#2309)
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 3da20a7 init
add a6325e6 Reduce image size by 29.74% through lossless compression algorithm (#2332)
add a42631f add deleteData Func in session pool (#2388)
add 9327fc4 [IOTDB-1071] Built-in UDF registration service (#2380)
add 36794dc [IOTDB-1074] Add interface `getDataType` for UDFParameters (#2378)
add 8bf4746 Remove useless imports in python client (#2294)
add 3192cda change the table format of md doc in spark module (#2393)
add 84d7527 fix coordinator not init bug after restart (#2383)
add 886b99d Add check local nodes in partitiontable's all nodes or not when restart the cluster
add 8966bf1 Merge pull request #2391 from neuyilan/apache_master_1230_fix_restart_bug
add af1da9d [IOTDB-1069] restrict the flushing memtable number to avoid OOM when mem_control is disabled (#2315)
add bebad07 fix zeppelin doc headings (#2396)
add 482b5b3 fix the cli doc typo (#2399)
add e4ddf81 [IOTDB-1098] Add interface `validate` for UDF (#2406)
add e28208c change udf and tracing ut root path to target (#2411)
add 6d25ba5 refactor node management
add d99432a remove a done todo
add 31c4d43 Merge branch 'master' into cluster_node_management
add 44a6155 fix tests
add 0255b85 fix test
add e7b1421 fix no waiting after time_out
add 6f3d021 Merge branch 'master' into cluster_node_management
add 90cc875 fix import
add 08400ad Merge pull request #2359 from apache/cluster_node_management
add 662a1b7 fix metaGroupMember bug when follower foward non-query plan to leader
add 1c3c2e9 remove unused import
add d509f6e Merge pull request #2404 from mychaow/fix_metaGroupMember_bug
add 1cf50bb Merge branch 'master' of https://github.com/apache/iotdb into NewTsFile
add 990e3a7 fix test
No new revisions were added by this update.
Summary of changes:
.github/pull_request_template.md | 93 +++
.github/workflows/sonar_and_coverall.yml | 4 +-
.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 | 28 +-
.../iotdb/cluster/client/DataClientProvider.java | 17 +-
.../cluster/client/async/AsyncClientPool.java | 87 +--
.../iotdb/cluster/client/sync/SyncClientPool.java | 39 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 14 +-
.../iotdb/cluster/config/ClusterConstant.java | 6 +-
.../iotdb/cluster/coordinator/Coordinator.java | 598 +++++++++++++++++
.../apache/iotdb/cluster/log/LogDispatcher.java | 4 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 4 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 2 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 2 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 14 +-
.../cluster/partition/slot/SlotPartitionTable.java | 4 +-
.../cluster/query/ClusterConcatPathOptimizer.java | 4 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 10 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 9 -
.../cluster/query/fill/ClusterPreviousFill.java | 11 +-
.../cluster/query/manage/QueryCoordinator.java | 115 +---
.../iotdb/cluster/query/reader/DataSourceInfo.java | 2 +-
.../apache/iotdb/cluster/server/ClientServer.java | 26 +-
.../iotdb/cluster/server/DataClusterServer.java | 2 +-
.../iotdb/cluster/server/MetaClusterServer.java | 17 +-
.../handlers/caller/AppendNodeEntryHandler.java | 6 +-
.../server/handlers/caller/HeartbeatHandler.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 15 +-
.../cluster/server/member/MetaGroupMember.java | 613 +++--------------
.../iotdb/cluster/server/member/RaftMember.java | 100 ++-
.../cluster/server/{ => monitor}/NodeReport.java | 3 +-
.../manage => server/monitor}/NodeStatus.java | 41 +-
.../monitor/NodeStatusManager.java} | 87 +--
.../iotdb/cluster/server/{ => monitor}/Peer.java | 2 +-
.../iotdb/cluster/server/{ => monitor}/Timer.java | 15 +-
.../cluster/server/service/BaseSyncService.java | 7 +-
.../cluster/server/service/MetaAsyncService.java | 6 +
.../cluster/server/service/MetaSyncService.java | 5 +
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 2 +-
.../cluster/client/DataClientProviderTest.java | 12 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 16 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 7 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 6 +
.../log/catchup/SnapshotCatchUpTaskTest.java | 6 +
.../manage/MetaSingleSnapshotLogManagerTest.java | 3 +
.../cluster/log/snapshot/DataSnapshotTest.java | 10 +
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 5 +
.../cluster/partition/SlotPartitionTableTest.java | 14 -
.../apache/iotdb/cluster/query/BaseQueryTest.java | 5 +-
.../query/ClusterPhysicalGeneratorTest.java | 10 +-
.../cluster/query/ClusterPlanExecutorTest.java | 4 +-
.../cluster/query/manage/QueryCoordinatorTest.java | 15 +-
.../caller/AppendNodeEntryHandlerTest.java | 2 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 5 +
.../server/heartbeat/HeartbeatThreadTest.java | 5 +
.../server/heartbeat/MetaHeartbeatThreadTest.java | 5 +
.../cluster/server/member/DataGroupMemberTest.java | 5 +
.../iotdb/cluster/server/member/MemberTest.java | 19 +-
.../cluster/server/member/MetaGroupMemberTest.java | 76 ++-
docs/SystemDesign/TsFile/Format.md | 4 +-
docs/UserGuide/Client/Status Codes.md | 8 +
docs/UserGuide/Concept/SDT.md | 63 ++
.../Ecosystem Integration/Zeppelin-IoTDB.md | 189 ++++++
.../Operation Manual/UDF User Defined Function.md | 511 ++++++++++++++
docs/UserGuide/Server/Cluster Setup.md | 2 +-
docs/UserGuide/System Tools/Sync Tool.md | 2 +-
docs/zh/SystemDesign/TsFile/Format.md | 4 +-
docs/zh/UserGuide/Client/Command Line Interface.md | 2 +-
docs/zh/UserGuide/Client/Status Codes.md | 9 +-
docs/zh/UserGuide/Concept/SDT.md | 61 ++
.../Ecosystem Integration/Zeppelin-IoTDB.md | 191 ++++++
.../Operation Manual/UDF User Defined Function.md | 512 ++++++++++++++
docs/zh/UserGuide/Server/Cluster Setup.md | 2 +-
docs/zh/UserGuide/System Tools/Sync Tool.md | 2 +-
example/pom.xml | 1 +
example/udf/pom.xml | 82 +++
.../java/org/apache/iotdb/udf/UDTFExample.java | 56 ++
grafana/img/add_data_source.png | Bin 175851 -> 108927 bytes
grafana/img/add_graph.png | Bin 723579 -> 364163 bytes
grafana/img/edit_data_source.png | Bin 313673 -> 177869 bytes
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 2 +-
.../resources/conf/iotdb-engine.properties | 38 +-
server/src/assembly/resources/conf/logback.xml | 24 +-
.../org/apache/iotdb/db/auth/AuthException.java | 5 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 20 +-
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 2 +-
.../db/auth/authorizer/LocalFileAuthorizer.java | 2 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 10 +-
.../apache/iotdb/db/auth/entity/PathPrivilege.java | 4 +-
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 120 +++-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 12 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 49 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../compaction/CompactionMergeTaskPoolManager.java | 32 +-
.../db/engine/compaction/TsFileManagement.java | 22 +-
.../level/LevelCompactionTsFileManagement.java | 192 +++---
.../no/NoCompactionTsFileManagement.java | 5 -
.../engine/compaction/utils/CompactionUtils.java | 12 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 2 +-
.../io/LocalTextModificationAccessor.java | 61 +-
.../engine/storagegroup/StorageGroupProcessor.java | 97 +--
.../db/engine/storagegroup/TsFileProcessor.java | 19 +-
.../UDFRegistrationException.java} | 72 +-
.../org/apache/iotdb/db/metadata/MManager.java | 8 +
.../iotdb/db/metadata/logfile/MLogWriter.java | 24 +-
.../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 | 22 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 11 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 128 +++-
.../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 | 132 ++--
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 192 ++++--
.../db/query/aggregation/AggregateResult.java | 2 +-
.../db/query/aggregation/AggregationType.java | 1 -
.../db/query/control/QueryResourceManager.java | 8 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../dataset/DirectAlignByTimeDataSet.java} | 74 +--
.../dataset/DirectNonAlignDataSet.java} | 72 +-
.../apache/iotdb/db/query/dataset/ListDataSet.java | 16 +-
.../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 +++
.../org/apache/iotdb/db/query/udf/api/UDF.java | 44 ++
.../org/apache/iotdb/db/query/udf/api/UDTF.java | 121 ++++
.../apache/iotdb/db/query/udf/api/access/Row.java | 119 ++++
.../udf/api/access/RowIterator.java} | 94 +--
.../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 +++
.../parameter/UDFParameterValidator.java | 209 ++++++
.../api/customizer/parameter/UDFParameters.java | 149 +++++
.../api/customizer/strategy/AccessStrategy.java | 64 ++
.../strategy/RowByRowAccessStrategy.java | 61 ++
.../strategy/SlidingSizeWindowAccessStrategy.java | 123 ++++
.../strategy/SlidingTimeWindowAccessStrategy.java | 249 +++++++
.../UDFAttributeNotProvidedException.java} | 22 +-
.../udf/api/exception/UDFException.java} | 22 +-
.../UDFInputSeriesDataTypeNotValidException.java} | 29 +-
.../UDFInputSeriesIndexNotValidException.java} | 24 +-
.../UDFInputSeriesNumberNotValidException.java} | 27 +-
.../exception/UDFParameterNotValidException.java} | 22 +-
.../udf/builtin/BuiltinFunction.java} | 26 +-
.../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 | 115 ++++
.../iotdb/db/query/udf/core/input/InputLayer.java | 563 ++++++++++++++++
.../iotdb/db/query/udf/core/input/SafetyLine.java | 60 ++
.../udf/core/reader/LayerPointReader.java} | 93 +--
.../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} | 89 +--
.../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 | 78 +++
.../query/udf/service/UDFRegistrationService.java | 398 +++++++++++
.../apache/iotdb/db/rescon/MemTableManager.java | 116 ++++
.../org/apache/iotdb/db/rescon/SystemInfo.java | 1 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 10 +-
.../org/apache/iotdb/db/service/ServiceType.java | 9 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 115 ++--
.../db/sync/receiver/load/FileLoaderManager.java | 4 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 25 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 48 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 29 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 12 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 9 -
.../main/resources/iotdb/ui/static/iotdb-logo.png | Bin 1768 -> 1187 bytes
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 144 ++++
.../{ => authorizer}/LocalFileAuthorizerTest.java | 295 ++++----
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 107 +--
.../iotdb/db/auth/entity/PathPrivilegeTest.java} | 36 +-
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 33 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 44 ++
.../auth/{ => role}/LocalFileRoleAccessorTest.java | 13 +-
.../auth/{ => role}/LocalFileRoleManagerTest.java | 45 +-
.../auth/{ => user}/LocalFileUserAccessorTest.java | 13 +-
.../auth/{ => user}/LocalFileUserManagerTest.java | 69 +-
.../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 | 438 ++++++++++++
.../db/integration/IoTDBUDFWindowQueryIT.java | 513 ++++++++++++++
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 738 +++++++++++++++++++++
.../db/integration/IoTDBUDTFHybridQueryIT.java | 166 +++++
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 337 ++++++++++
.../apache/iotdb/db/metadata/PartialPathTest.java | 34 +-
.../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 16 +
.../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} | 85 ++-
.../datastructure/SerializableLongTVListTest.java | 78 +++
.../SerializableRowRecordListTest.java | 143 ++++
.../udf/datastructure/SerializableTVListTest.java} | 79 ++-
.../iotdb/db/query/udf/example/Accumulator.java | 90 +++
.../apache/iotdb/db/query/udf/example/Adder.java | 89 +++
.../apache/iotdb/db/query/udf/example/Counter.java | 76 +++
.../org/apache/iotdb/db/query/udf/example/Max.java | 72 ++
.../iotdb/db/query/udf/example/Multiplier.java | 62 ++
.../SlidingSizeWindowConstructorTester0.java | 53 ++
.../SlidingSizeWindowConstructorTester1.java | 62 ++
.../SlidingTimeWindowConstructionTester.java | 69 ++
.../db/query/udf/example/TerminateTester.java | 64 ++
.../iotdb/db/query/udf/example/ValidateTester.java | 46 ++
.../iotdb/db/utils/CopyOnReadLinkedListTest.java | 67 ++
.../iotdb/db/utils/EncodingInferenceUtilsTest.java | 45 ++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 8 +
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 114 ++++
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 64 ++
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 312 +++++++++
.../db/utils/datastructure/BinaryTVListTest.java | 58 ++
.../db/utils/datastructure/BooleanTVListTest.java | 62 ++
.../db/utils/datastructure/DoubleTVListTest.java | 72 ++
.../db/utils/datastructure/FloatTVListTest.java | 72 ++
.../db/utils/datastructure/IntTVListTest.java | 71 ++
.../db/utils/datastructure/LongTVListTest.java | 18 +
.../apache/iotdb/db/writelog/PerformanceTest.java | 15 +-
server/src/test/resources/iotdb-engine.properties | 2 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 2 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 -
.../apache/iotdb/session/SessionConnection.java | 2 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 26 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 10 +-
.../java/org/apache/iotdb/session/SessionUT.java | 2 +-
site/src/main/.vuepress/config.js | 26 +-
.../public/img/contributor-avatar/jlq.png | Bin 122303 -> 98500 bytes
.../public/img/contributor-avatar/kfx.jpeg | Bin 134257 -> 119029 bytes
.../public/img/contributor-avatar/xdh.jpg | Bin 136069 -> 123718 bytes
.../.vuepress/public/img/contributor-avatar/yt.jpg | Bin 131028 -> 115804 bytes
.../public/img/contributor-avatar/zss.jpg | Bin 98085 -> 91455 bytes
site/src/main/.vuepress/public/img/home-Slide1.png | Bin 438294 -> 323108 bytes
site/src/main/.vuepress/public/img/home-Slide2.png | Bin 440893 -> 323620 bytes
site/src/main/.vuepress/public/img/home-Slide3.png | Bin 441335 -> 324332 bytes
site/src/main/.vuepress/public/img/home-icon2.png | Bin 5529 -> 4463 bytes
site/src/main/.vuepress/public/img/home-icon3.png | Bin 20637 -> 10753 bytes
site/src/main/.vuepress/public/img/home-icon4.png | Bin 13225 -> 8681 bytes
site/src/main/.vuepress/public/img/home-icon5.png | Bin 1989 -> 1531 bytes
site/src/main/.vuepress/public/img/home-icon6.png | Bin 16502 -> 11537 bytes
site/src/main/.vuepress/public/img/logo.png | Bin 31747 -> 21687 bytes
site/src/main/.vuepress/public/img/tools.jpg | Bin 347602 -> 294103 bytes
.../theme/global-components/Contributor.vue | 14 +
spark-iotdb-connector/Readme.md | 32 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/README.md | 31 +-
thrift/src/main/thrift/cluster.thrift | 7 +
.../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 +-
zeppelin-interpreter/README.md | 186 ------
zeppelin-interpreter/pom.xml | 32 +-
335 files changed, 18326 insertions(+), 3272 deletions(-)
create mode 100644 .github/pull_request_template.md
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/coordinator/Coordinator.java
rename cluster/src/main/java/org/apache/iotdb/cluster/server/{ => monitor}/NodeReport.java (98%)
rename cluster/src/main/java/org/apache/iotdb/cluster/{query/manage => server/monitor}/NodeStatus.java (59%)
copy cluster/src/main/java/org/apache/iotdb/cluster/{query/manage/QueryCoordinator.java => server/monitor/NodeStatusManager.java} (72%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/{ => monitor}/Peer.java (97%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/{ => monitor}/Timer.java (97%)
create mode 100644 docs/UserGuide/Ecosystem Integration/Zeppelin-IoTDB.md
create mode 100644 docs/UserGuide/Operation Manual/UDF User Defined Function.md
create mode 100644 docs/zh/UserGuide/Ecosystem Integration/Zeppelin-IoTDB.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
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/api/UDF.java
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/{auth/AuthException.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/UDFParameterValidator.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
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/exception/UDFAttributeNotProvidedException.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/exception/UDFException.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/exception/UDFInputSeriesIndexNotValidException.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/exception/UDFInputSeriesNumberNotValidException.java} (55%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/api/exception/UDFParameterNotValidException.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/UpdateOperator.java => query/udf/builtin/BuiltinFunction.java} (63%)
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/{auth/AuthException.java => query/udf/core/reader/LayerPointReader.java} (52%)
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 server/src/main/java/org/apache/iotdb/db/{auth/authorizer/LocalFileAuthorizer.java => 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/main/java/org/apache/iotdb/db/rescon/MemTableManager.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/auth/AuthorityCheckerTest.java
rename server/src/test/java/org/apache/iotdb/db/auth/{ => authorizer}/LocalFileAuthorizerTest.java (52%)
copy server/src/{main/java/org/apache/iotdb/db/auth/entity/PrivilegeType.java => test/java/org/apache/iotdb/db/auth/entity/PathPrivilegeTest.java} (51%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/dataset/EmptyDataSet.java => server/src/test/java/org/apache/iotdb/db/auth/entity/RoleTest.java (53%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/auth/entity/UserTest.java
rename server/src/test/java/org/apache/iotdb/db/auth/{ => role}/LocalFileRoleAccessorTest.java (85%)
rename server/src/test/java/org/apache/iotdb/db/auth/{ => role}/LocalFileRoleManagerTest.java (73%)
rename server/src/test/java/org/apache/iotdb/db/auth/{ => user}/LocalFileUserAccessorTest.java (89%)
rename server/src/test/java/org/apache/iotdb/db/auth/{ => user}/LocalFileUserManagerTest.java (70%)
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/auth/AuthException.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
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/udf/example/ValidateTester.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/CopyOnReadLinkedListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/EncodingInferenceUtilsTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/MemUtilsTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/SchemaUtilsTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/SerializeUtilsTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/datastructure/BinaryTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/datastructure/BooleanTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/datastructure/DoubleTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/datastructure/FloatTVListTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/utils/datastructure/IntTVListTest.java
delete mode 100644 zeppelin-interpreter/README.md