This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster_scalability
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 327eb7e 1. fix ut tests 2. The two-stage relative order problem of
double logs is solved.
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 22740d3 Fix the condition of logger with the right level globally
(#2407)
add 85d4a00 [IOTDB-1068] Fix Time series metadata cache bug (#2316)
add acf33e2 fix merge bug for #2404
add 8ed7071 Merge pull request #2415 from mychaow/fix_merge_bug_2404
add 9da7b72 split condition for waitPrevLog into multiple conditions
add 7d43cbd Merge branch 'master' into cluster_split_condition
add 5913109 fix tests and code smells
add bc9ae25 Merge pull request #2394 from apache/cluster_split_condition
add d9fb310 [IOTDB-1077] add insertOneDeviceRecords API in java session
(#2397)
add b686e94 make serialization pool in LogDispatcher static to reduece
the number of pools
add 0fa6736 Merge pull request #2421 from apache/reduce_serialization_pool
add 6d15e3c add the udf contribution guide (#2429)
add cdfbf40 expose enablePartition parameter into
iotdb-engines.properpties (#2433)
add 805d3ab [IOTDB-1103] Fix frame size larger than max length error
(#2431)
add 44a055c [IOTDB-1076] Create interface of TimeIndex (#2340)
add de8493f Fix compaction recover path bug (#2422)
add b0083ea [IOTDB-1073] Built-in UDTFs (#2417)
add e2014e3 [ISSUE-2351] fix the case that column length is not right in
CLI when the value contains Chinese characters (#2427)
add 90b6360 fix the analyse startup check bug
add 3a7f97b make the check logic more understandable
add cf9c31a Merge pull request #2432 from
neuyilan/apache_master_0106_fix_check_start_bug
add 7e2f27c Switch Zeppelin connector from Session to JDBC (#2414)
add f24f469 fix delete timeseries bug (#2441)
add d5f1849 Improve dropping non-existent tag/attribute code (#2418)
add 5b67483 Bump commons-collections4 from 4.0 to 4.4 to avoid a security
bug (#2331)
add 4b58c28 add debug log for IOTDB-1101 (#2424)
add 682e9b8 Remove EnvironmentUtil in the cluster module and optimize UT
(#2423)
add 0270c03 Fix bugs on query statements that ignore timestamps, namely,
the result's first column is not time when using Zeppelin. (#2447)
add 38eb730 Execute compaction after sync and load is called (#2439)
add 1a302f5 Fix a bug of sync last query not right (#2403)
add 5a05c1c Revert "Fix a bug of sync last query not right (#2403)"
(#2453)
add ca31fef Revert "Execute compaction after sync and load is called
(#2439)"
add 6add2e0 e2e: add a simple E2E case and set up the workflow (#2166)
add de17d23 [IOTDB-1104] Refactor the error handling process of query
exceptions (#2436)
add 95de08d Fix compaction recover list bug (#2451)
add 270ffdb fix copyright declaim in NOTICE; remove 'incubating' out of
README_ZH.md; simplify pull_request_template.md (#2465)
add dfcf80d fix metrics page nullpoint bug (#2459)
add 09e21ed Add monitor and qp tests (#2283)
add bdb5d3e Optimize synchronizing scope in MLogWriter.java (#2448)
add 0a722ba fix the test in RaftLogManagerTest
add ee293e6 Merge pull request #2461 from
neuyilan/apache_master_0110_applier_bug_fix
add f2218dd allow compress buffer to oversize maxLength during compression
add 488511d rename maxSoftLength to softMaxLength
add d7b466c Merge pull request #2322 from
apache/change_transport_resize_policy
add 5b3b423 add thrift readme
add ab2b3db minor fixes
add 72ba8b9 add options of using maven parameter
add c427797 Merge pull request #2227 from apache/add_thrift_readme
add 70b228a show devices limit (#2389)
add 347958c fix: print user not logged in info when the user has logged
in (#2472)
add 680bb1a enable TsFile insertTablet with only a template (#2474)
add 06b576e Revert inplace merge (#2398)
add cf44a1d remove duplicate paramas in server script (#2463)
add 7a67bc5 add docker file for 0.11.1 and 0.11.2; fix invalid urls in
preivous d… (#2467)
add 74cbf19 [ISSUE-2479] Remove redundant logic in
session.genTSInsertRecordsOfOneDeviceReq() (#2480)
add 4acc515 [IOTDB-1094] Improve some code writing and name typo (#2382)
add a707012 [ISSUE-2476] fix the case that isNumber method returns true
when the input is "NaN" (#2477)
add 0e88973 fix import csv which can't import time format str (#2409)
add 663d910 [ISSUE-2419] Server test logs contains lots of useless
content (#2420)
add 344c954 [IOTDB-1108] Add error log to print file name while error
happened (#2450)
add 652be96 [IOTDB-965] Add timeout in query (#2352)
add a7de988 fix the apply bug in raftLogManager
add 32317b7 fix the test in RaftLogManager
add ab49f82 remove debug message
add e09b377 Merge pull request #2489 from
neuyilan/apache_master_0113_fix_apply_bug
new f342899 merge master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docker/src/main/Dockerfile-0.11.0 => .dockerignore | 24 +-
.github/pull_request_template.md | 37 +-
.github/workflows/e2e.yml | 52 ++
NOTICE | 2 +-
NOTICE-binary | 2 +-
README.md | 15 +
README_ZH.md | 14 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 17 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 138 ++-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 2 +
cli/src/main/java/org/apache/iotdb/cli/WinCli.java | 3 +
.../org/apache/iotdb/cli/utils/IoTPrinter.java | 107 +++
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 63 +-
cluster/pom.xml | 7 +
cluster/src/assembly/resources/sbin/start-node.sh | 2 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 20 +-
.../apache/iotdb/cluster/RemoteTsFileResource.java | 41 +-
.../cluster/client/async/AsyncClientPool.java | 79 +-
.../iotdb/cluster/client/sync/SyncClientPool.java | 24 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 14 +-
.../iotdb/cluster/config/ClusterConstant.java | 33 +-
.../iotdb/cluster/coordinator/Coordinator.java | 602 +++++++++++++
.../apache/iotdb/cluster/log/LogDispatcher.java | 16 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 4 +-
.../iotdb/cluster/log/applier/MetaLogApplier.java | 8 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 2 +-
.../cluster/log/manage/CommittedEntryManager.java | 5 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 1 +
.../iotdb/cluster/log/manage/RaftLogManager.java | 26 +-
.../log/manage/UnCommittedEntryManager.java | 10 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 10 +-
.../cluster/query/manage/QueryCoordinator.java | 115 +--
.../apache/iotdb/cluster/server/ClientServer.java | 28 +-
.../iotdb/cluster/server/DataClusterServer.java | 2 +-
.../iotdb/cluster/server/MetaClusterServer.java | 17 +-
.../apache/iotdb/cluster/server/RaftServer.java | 7 +-
.../handlers/caller/AppendNodeEntryHandler.java | 6 +-
.../server/handlers/caller/HeartbeatHandler.java | 2 +-
.../cluster/server/heartbeat/HeartbeatThread.java | 8 +-
.../cluster/server/member/DataGroupMember.java | 17 +-
.../cluster/server/member/MetaGroupMember.java | 198 +++--
.../iotdb/cluster/server/member/RaftMember.java | 130 ++-
.../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/MetaAsyncService.java | 6 +
.../cluster/server/service/MetaSyncService.java | 5 +
.../apache/iotdb/cluster/utils/ClusterUtils.java | 9 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 2 +-
.../iotdb/cluster/common/EnvironmentUtils.java | 218 -----
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 4 +-
.../cluster/integration/BaseSingleNodeTest.java | 2 +-
.../iotdb/cluster/integration/SingleNodeTest.java | 7 +-
.../iotdb/cluster/log/CommitLogCallbackTest.java | 2 +-
.../iotdb/cluster/log/CommitLogTaskTest.java | 2 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 2 +-
.../log/applier/AsyncDataLogApplierTest.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 13 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 9 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 8 +-
.../log/catchup/SnapshotCatchUpTaskTest.java | 8 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 3 +
.../cluster/log/manage/RaftLogManagerTest.java | 22 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 12 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 5 +
.../iotdb/cluster/partition/SlotManagerTest.java | 2 +-
.../cluster/partition/SlotPartitionTableTest.java | 2 +-
.../apache/iotdb/cluster/query/BaseQueryTest.java | 15 +-
.../query/ClusterAggregateExecutorTest.java | 48 +-
.../query/ClusterDataQueryExecutorTest.java | 22 +-
.../cluster/query/ClusterFillExecutorTest.java | 72 +-
.../cluster/query/ClusterPlanExecutorTest.java | 8 +-
.../cluster/query/ClusterQueryRouterTest.java | 216 ++---
.../ClusterGroupByNoVFilterDataSetTest.java | 64 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 74 +-
.../query/groupby/MergeGroupByExecutorTest.java | 83 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 146 ++--
.../cluster/query/manage/QueryCoordinatorTest.java | 15 +-
.../query/reader/ClusterTimeGeneratorTest.java | 34 +-
.../cluster/query/reader/DatasourceInfoTest.java | 16 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 122 +--
.../query/reader/RemoteSimpleSeriesReaderTest.java | 136 +--
.../caller/AppendGroupEntryHandlerTest.java | 2 +-
.../caller/AppendNodeEntryHandlerTest.java | 4 +-
.../handlers/caller/ElectionHandlerTest.java | 2 +-
.../handlers/caller/HeartbeatHandlerTest.java | 2 +-
.../handlers/caller/LogCatchUpHandlerTest.java | 2 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 5 +
.../server/heartbeat/HeartbeatThreadTest.java | 10 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 5 +
.../cluster/server/member/DataGroupMemberTest.java | 129 +--
.../iotdb/cluster/server/member/MemberTest.java | 35 +-
.../cluster/server/member/MetaGroupMemberTest.java | 83 +-
docker/src/main/Dockerfile | 46 +-
docker/src/main/Dockerfile-0.10.0 | 4 +-
docker/src/main/Dockerfile-0.10.1 | 4 +-
docker/src/main/Dockerfile-0.11.0 | 4 +-
.../main/{Dockerfile-0.11.0 => Dockerfile-0.11.1} | 10 +-
.../main/{Dockerfile-0.11.0 => Dockerfile-0.11.2} | 10 +-
docs/UserGuide/Client/Programming - Native API.md | 18 +
docs/UserGuide/Client/Status Codes.md | 2 +
.../Ecosystem Integration/Zeppelin-IoTDB.md | 20 +-
docs/UserGuide/Operation Manual/Administration.md | 2 +
.../DML Data Manipulation Language.md | 155 +++-
.../Operation Manual/UDF User Defined Function.md | 192 ++++-
docs/UserGuide/Server/Config Manual.md | 18 +
docs/UserGuide/System Tools/CSV Tool.md | 1 +
docs/zh/UserGuide/Client/Command Line Interface.md | 2 +-
.../UserGuide/Client/Programming - Native API.md | 14 +
docs/zh/UserGuide/Client/Status Codes.md | 2 +
.../Ecosystem Integration/Zeppelin-IoTDB.md | 20 +-
.../UserGuide/Operation Manual/Administration.md | 2 +
.../DML Data Manipulation Language.md | 156 +++-
.../Operation Manual/UDF User Defined Function.md | 195 ++++-
docs/zh/UserGuide/Server/Config Manual.md | 17 +
docs/zh/UserGuide/System Tools/CSV Tool.md | 1 +
.../main/java/org/apache/iotdb/SessionExample.java | 20 +-
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
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 18 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 15 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 20 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 4 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 6 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 8 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 29 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 7 +
pom.xml | 2 +-
.../file-changelists/TsFileResource-changelist.md | 8 +-
.../resources/conf/iotdb-engine.properties | 28 +
server/src/assembly/resources/conf/logback.xml | 25 +-
server/src/assembly/resources/sbin/start-server.sh | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 43 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 14 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 16 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 37 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 32 +-
.../compaction/CompactionMergeTaskPoolManager.java | 32 +-
.../db/engine/compaction/TsFileManagement.java | 38 +-
.../level/LevelCompactionTsFileManagement.java | 258 +++---
.../no/NoCompactionTsFileManagement.java | 10 +-
.../engine/compaction/utils/CompactionLogger.java | 2 +-
.../engine/compaction/utils/CompactionUtils.java | 12 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 24 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 48 +-
.../merge/selector/MaxFileMergeFileSelector.java | 11 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 138 ++-
.../db/engine/merge/task/MergeMultiChunkTask.java | 4 +-
.../io/LocalTextModificationAccessor.java | 61 +-
.../engine/storagegroup/StorageGroupProcessor.java | 220 ++---
.../db/engine/storagegroup/TsFileProcessor.java | 89 +-
.../db/engine/storagegroup/TsFileResource.java | 356 +++-----
.../storagegroup/timeindex/DeviceTimeIndex.java | 308 +++++++
.../storagegroup/timeindex/FileTimeIndex.java | 193 +++++
.../engine/storagegroup/timeindex/ITimeIndex.java | 138 +++
.../storagegroup/timeindex/TimeIndexLevel.java} | 43 +-
.../apache/iotdb/db/exception/IoTDBException.java | 21 +
.../db/exception/PartitionViolationException.java | 8 +-
...xception.java => QueryIdNotExsitException.java} | 10 +-
.../iotdb/db/exception/StorageEngineException.java | 2 +-
.../db/exception/UDFRegistrationException.java | 7 +-
.../iotdb/db/exception/WriteProcessException.java | 4 +
.../metadata/AliasAlreadyExistException.java | 1 +
.../exception/metadata/IllegalPathException.java | 1 +
.../db/exception/metadata/MetadataException.java | 8 +
.../metadata/PathAlreadyExistException.java | 1 +
.../exception/metadata/PathNotExistException.java | 20 +-
.../metadata/StorageGroupNotSetException.java | 5 +
.../db/exception/query/OutOfTTLException.java | 2 +-
.../db/exception/query/QueryProcessException.java | 6 +-
.../QueryTimeoutRuntimeException.java} | 68 +-
.../org/apache/iotdb/db/metadata/MManager.java | 61 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 77 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 143 +---
.../apache/iotdb/db/metrics/ui/MetricsPage.java | 2 +-
.../apache/iotdb/db/monitor/MonitorConstants.java | 5 -
.../org/apache/iotdb/db/monitor/StatMonitor.java | 6 +-
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 123 +--
.../main/java/org/apache/iotdb/db/qp/Planner.java | 1 +
.../apache/iotdb/db/qp/constant/SQLConstant.java | 12 +
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 8 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 192 ++++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 5 +-
...TracingOperator.java => KillQueryOperator.java} | 20 +-
.../db/qp/logical/sys/RemoveFileOperator.java | 5 -
.../db/qp/logical/sys/ShowDevicesOperator.java | 18 +
.../iotdb/db/qp/logical/sys/TracingOperator.java | 10 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 8 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 25 +
.../physical/crud/InsertRowsOfOneDevicePlan.java | 154 ++++
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 3 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 3 +-
.../db/qp/physical/sys/AlterTimeSeriesPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 2 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 6 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 14 +-
.../{ShowDevicesPlan.java => KillQueryPlan.java} | 25 +-
.../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 13 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 51 +-
.../physical/sys/ShowQueryProcesslistPlan.java} | 56 +-
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 56 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 34 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 31 +-
.../db/qp/{constant => utils}/DatetimeUtils.java | 12 +-
.../db/query/aggregation/AggregateResult.java | 3 +-
.../db/query/aggregation/impl/AvgAggrResult.java | 10 +-
.../db/query/aggregation/impl/SumAggrResult.java | 10 +-
.../iotdb/db/query/control/QueryFileManager.java | 2 +
.../db/query/control/QueryResourceManager.java | 3 +
.../iotdb/db/query/control/QueryTimeManager.java | 172 ++++
.../iotdb/db/query/control/TracingManager.java | 2 +-
.../apache/iotdb/db/query/dataset/ListDataSet.java | 12 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 22 +
.../dataset/RawQueryDataSetWithoutValueFilter.java | 39 +-
.../apache/iotdb/db/query/dataset/ShowDataSet.java | 78 ++
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 58 ++
.../db/query/dataset/ShowTimeseriesDataSet.java | 46 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 2 +-
.../dataset/groupby/GroupByEngineDataSet.java | 8 +-
.../groupby/GroupByWithValueFilterDataSet.java | 3 +-
.../db/query/executor/AggregationExecutor.java | 4 +-
.../db/query/executor/RawDataQueryExecutor.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 14 +
.../org/apache/iotdb/db/query/udf/api/UDF.java | 15 +
.../org/apache/iotdb/db/query/udf/api/UDTF.java | 22 +-
.../db/query/udf/api/collector/PointCollector.java | 4 +-
.../api/customizer/config/UDTFConfigurations.java | 3 +-
.../parameter/UDFParameterValidator.java | 209 +++++
.../api/customizer/parameter/UDFParameters.java | 32 +
.../strategy/SlidingTimeWindowAccessStrategy.java | 2 +-
.../UDFAttributeNotProvidedException.java | 9 +-
.../udf/api/exception/UDFException.java} | 62 +-
.../UDFInputSeriesDataTypeNotValidException.java} | 34 +-
.../UDFInputSeriesIndexNotValidException.java} | 60 +-
.../UDFInputSeriesNumberNotValidException.java} | 17 +-
.../UDFParameterNotValidException.java} | 56 +-
.../db/query/udf/builtin/BuiltinFunction.java | 76 ++
.../iotdb/db/query/udf/builtin/UDTFAbs.java} | 148 ++--
.../udf/{api/UDF.java => builtin/UDTFAcos.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFAsin.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFAtan.java} | 57 +-
.../iotdb/db/query/udf/builtin/UDTFBottomK.java | 105 +++
.../udf/{api/UDF.java => builtin/UDTFCeil.java} | 57 +-
.../db/query/udf/builtin/UDTFCommonDerivative.java | 62 ++
.../udf/builtin/UDTFCommonValueDifference.java | 60 ++
.../iotdb/db/query/udf/builtin/UDTFContains.java} | 110 +--
.../udf/{api/UDF.java => builtin/UDTFCos.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFDegrees.java} | 57 +-
.../db/query/udf/builtin/UDTFDerivative.java} | 111 +--
.../udf/{api/UDF.java => builtin/UDTFExp.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFFloor.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFLog.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFLog10.java} | 57 +-
.../iotdb/db/query/udf/builtin/UDTFMatches.java} | 111 +--
.../iotdb/db/query/udf/builtin/UDTFMath.java | 89 ++
.../udf/builtin/UDTFNonNegativeDerivative.java | 63 ++
.../builtin/UDTFNonNegativeValueDifference.java | 61 ++
.../udf/{api/UDF.java => builtin/UDTFRadians.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFRound.java} | 57 +-
.../iotdb/db/query/udf/builtin/UDTFSelectK.java | 156 ++++
.../udf/{api/UDF.java => builtin/UDTFSign.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFSin.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFSqrt.java} | 57 +-
.../udf/{api/UDF.java => builtin/UDTFTan.java} | 57 +-
.../db/query/udf/builtin/UDTFTimeDifference.java} | 110 +--
.../iotdb/db/query/udf/builtin/UDTFTopK.java | 103 +++
.../db/query/udf/builtin/UDTFValueDifference.java} | 107 ++-
.../iotdb/db/query/udf/builtin/UDTFValueTrend.java | 73 ++
.../db/query/udf/core/executor/UDTFExecutor.java | 35 +-
.../udf/core/transformer/UDFQueryTransformer.java | 18 +-
.../query/udf/service/UDFClassLoaderManager.java | 9 +-
.../udf/service/UDFRegistrationInformation.java | 25 +-
.../query/udf/service/UDFRegistrationService.java | 145 +++-
.../apache/iotdb/db/rescon/MemTableManager.java | 116 +++
.../org/apache/iotdb/db/rescon/SystemInfo.java | 1 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 9 +-
.../apache/iotdb/db/service/RegisterManager.java | 17 +-
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 948 +++++++++------------
.../db/sync/receiver/load/FileLoaderManager.java | 6 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 41 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 4 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 11 +-
.../db/tools/watermark/WatermarkDetector.java | 2 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 4 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 9 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +
.../main/resources/iotdb/ui/static/iotdb-logo.png | Bin 1768 -> 1187 bytes
.../compaction/LevelCompactionMergeTest.java | 4 +-
.../compaction/LevelCompactionRecoverTest.java | 10 +-
.../LevelCompactionTsFileManagementTest.java | 1 -
.../NoCompactionTsFileManagementTest.java | 1 -
.../engine/storagegroup/TsFileProcessorTest.java | 14 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 1 -
.../iotdb/db/integration/IoTDBClearCacheIT.java | 2 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 35 +
.../apache/iotdb/db/integration/IoTDBFillIT.java | 6 +
.../db/integration/IoTDBFlushQueryMergeIT.java | 2 +-
.../integration/IoTDBGroupByFillWithRangeIT.java | 3 -
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 46 +-
.../iotdb/db/integration/IoTDBKillQueryTest.java | 84 ++
.../apache/iotdb/db/integration/IoTDBLastIT.java | 1 -
.../db/integration/IoTDBLevelCompactionIT.java | 1 -
.../db/integration/IoTDBLoadExternalTsfileIT.java | 20 +-
.../iotdb/db/integration/IoTDBMergeTest.java | 5 +
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 26 +-
.../db/integration/IoTDBQueryTimeoutTest.java | 154 ++++
.../iotdb/db/integration/IoTDBRestartIT.java | 40 +-
.../db/integration/IoTDBRpcCompressionIT.java | 1 -
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 3 -
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 52 ++
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 163 +++-
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 213 +++++
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 250 ++++++
.../db/integration/IoTDBUDTFHybridQueryIT.java | 6 +-
.../aggregation/IoTDBAggregationIT.java | 24 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 4 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 23 +
.../iotdb/db/monitor/IoTDBStatMonitorTest.java | 153 ++++
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 59 +-
.../qp/{plan => logical}/IndexLogicalPlanTest.java | 2 +-
.../qp/{plan => logical}/LogicalPlanSmallTest.java | 3 +-
.../qp/{plan => physical}/ConcatOptimizerTest.java | 3 +-
.../IndexSubMatchingPhysicalPlanTest.java | 3 +-
.../IndexWholeMatchingPhysicalPlanTest.java | 3 +-
.../db/qp/physical/PhysicalPlanSerializeTest.java | 305 +++++++
.../db/qp/{plan => physical}/PhysicalPlanTest.java | 4 +-
.../qp/{plan => physical}/SerializationTest.java | 3 +-
.../db/qp/sql/DatetimeQueryDataSetUtilsTest.java | 142 ---
.../IoTDBsqlVisitorTest.java} | 4 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 190 +++++
.../iotdb/db/query/control/TracingManagerTest.java | 15 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 2 +-
.../db/query/reader/series/SeriesReaderTest.java | 22 +-
.../iotdb/db/query/udf/example/Accumulator.java | 16 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 19 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 8 +-
...gSizeWindowConstructorTester1.java => Max.java} | 130 +--
.../iotdb/db/query/udf/example/Multiplier.java | 16 +-
.../SlidingSizeWindowConstructorTester0.java | 9 +-
.../SlidingSizeWindowConstructorTester1.java | 17 +-
.../SlidingTimeWindowConstructionTester.java | 17 +-
...onstructorTester1.java => TerminateTester.java} | 122 +--
.../{Multiplier.java => ValidateTester.java} | 100 +--
.../db/sync/receiver/load/FileLoaderTest.java | 8 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 4 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 35 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 13 +-
.../db/utils/datastructure/PrecisionTest.java | 22 +-
.../db/writelog/recover/DeviceStringTest.java | 8 +-
server/src/test/resources/iotdb-engine.properties | 2 +
server/src/test/resources/logback.xml | 1 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 9 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 14 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +-
.../rpc/TCompressedElasticFramedTransport.java | 45 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 41 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 2 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 11 +-
.../main/java/org/apache/iotdb/session/Config.java | 13 +-
.../java/org/apache/iotdb/session/Session.java | 176 +++-
.../apache/iotdb/session/SessionConnection.java | 34 +-
.../org/apache/iotdb/session/SessionDataSet.java | 12 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 81 ++
.../iotdb/session/IoTDBSessionComplexIT.java | 3 +-
.../iotdb/session/IoTDBSessionIteratorIT.java | 29 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 130 +++
.../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
spark-iotdb-connector/Readme.md | 32 +-
spark-tsfile/README.md | 31 +-
.../e2e/base/docker-compose.yaml | 54 +-
test/e2e/cases/README.md | 53 ++
.../e2e/cases/cli/README.md | 20 +-
.../e2e/cases/cli/cleanup.sh | 30 +-
.../e2e/cases/cli/docker-compose.yaml | 44 +-
test/e2e/cases/cli/res/init.sql | 26 +
.../Dockerfile-0.11.0 => test/e2e/cases/cli/run.sh | 51 +-
thrift/src/main/thrift/cluster.thrift | 7 +
thrift/src/main/thrift/rpc.thrift | 15 +
.../tsfile/encoding/bitpacking/IntPacker.java | 4 +-
.../tsfile/encoding/bitpacking/LongPacker.java | 4 +-
.../exception/QueryTimeoutRuntimeException.java | 68 +-
.../write/UnSupportedDataTypeException.java | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 195 +++--
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 20 +
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 13 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 22 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 5 -
.../tsfile/read/TimeSeriesMetadataReadTest.java | 87 ++
.../read/query/executor/QueryExecutorTest.java | 1 -
.../apache/iotdb/tsfile/utils/FileGenerator.java | 22 +-
.../tsfile/write/DefaultDeviceTemplateTest.java | 110 +++
zeppelin-interpreter/pom.xml | 2 +-
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 212 +++--
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 108 ++-
417 files changed, 12524 insertions(+), 5187 deletions(-)
copy docker/src/main/Dockerfile-0.11.0 => .dockerignore (51%)
create mode 100644 .github/workflows/e2e.yml
create mode 100644 cli/src/main/java/org/apache/iotdb/cli/utils/IoTPrinter.java
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%)
delete mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/common/EnvironmentUtils.java
copy docker/src/main/{Dockerfile-0.11.0 => Dockerfile-0.11.1} (77%)
copy docker/src/main/{Dockerfile-0.11.0 => Dockerfile-0.11.2} (84%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/timeindex/DeviceTimeIndex.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/timeindex/FileTimeIndex.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/timeindex/ITimeIndex.java
copy
server/src/main/java/org/apache/iotdb/db/{exception/StorageEngineException.java
=> engine/storagegroup/timeindex/TimeIndexLevel.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/exception/{PartitionViolationException.java
=> QueryIdNotExsitException.java} (76%)
copy
server/src/main/java/org/apache/iotdb/db/exception/{UDFRegistrationException.java
=> query/QueryTimeoutRuntimeException.java} (64%)
copy
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{TracingOperator.java
=> KillQueryOperator.java} (70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
copy
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowDevicesPlan.java
=> KillQueryPlan.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/{query/udf/api/UDF.java =>
qp/physical/sys/ShowQueryProcesslistPlan.java} (79%)
rename server/src/main/java/org/apache/iotdb/db/qp/{constant =>
utils}/DatetimeUtils.java (99%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/QueryTimeManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/ShowDataSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/ShowDevicesDataSet.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/api/customizer/parameter/UDFParameterValidator.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/write/UnSupportedDataTypeException.java
=>
server/src/main/java/org/apache/iotdb/db/query/udf/api/exception/UDFAttributeNotProvidedException.java
(72%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/UDFRegistrationException.java
=> query/udf/api/exception/UDFException.java} (76%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/StorageEngineException.java
=> query/udf/api/exception/UDFInputSeriesDataTypeNotValidException.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/UDFRegistrationException.java
=> query/udf/api/exception/UDFInputSeriesIndexNotValidException.java} (67%)
copy
server/src/main/java/org/apache/iotdb/db/{exception/metadata/StorageGroupNotSetException.java
=> query/udf/api/exception/UDFInputSeriesNumberNotValidException.java} (56%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/api/{UDF.java =>
exception/UDFParameterNotValidException.java} (79%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/BuiltinFunction.java
copy server/src/{test/java/org/apache/iotdb/db/query/udf/example/Adder.java =>
main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAbs.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFAcos.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFAsin.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFAtan.java} (79%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFBottomK.java
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFCeil.java} (79%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFCommonDerivative.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFCommonValueDifference.java
copy
server/src/{test/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java
=> main/java/org/apache/iotdb/db/query/udf/builtin/UDTFContains.java} (68%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFCos.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFDegrees.java} (79%)
copy
server/src/{test/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java
=> main/java/org/apache/iotdb/db/query/udf/builtin/UDTFDerivative.java} (62%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFExp.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFFloor.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFLog.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFLog10.java} (79%)
copy
server/src/{test/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java
=> main/java/org/apache/iotdb/db/query/udf/builtin/UDTFMatches.java} (66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFMath.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFNonNegativeDerivative.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFNonNegativeValueDifference.java
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFRadians.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFRound.java} (79%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFSelectK.java
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFSign.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFSin.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFSqrt.java} (79%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/{api/UDF.java =>
builtin/UDTFTan.java} (79%)
copy
server/src/{test/java/org/apache/iotdb/db/query/udf/example/Multiplier.java =>
main/java/org/apache/iotdb/db/query/udf/builtin/UDTFTimeDifference.java} (71%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFTopK.java
copy
server/src/{test/java/org/apache/iotdb/db/query/udf/example/Multiplier.java =>
main/java/org/apache/iotdb/db/query/udf/builtin/UDTFValueDifference.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFValueTrend.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/integration/IoTDBKillQueryTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryTimeoutTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFBuiltinFunctionIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/monitor/IoTDBStatMonitorTest.java
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
logical}/IndexLogicalPlanTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
logical}/LogicalPlanSmallTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
physical}/ConcatOptimizerTest.java (98%)
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
physical}/IndexSubMatchingPhysicalPlanTest.java (98%)
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
physical}/IndexWholeMatchingPhysicalPlanTest.java (98%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/physical/PhysicalPlanSerializeTest.java
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
physical}/PhysicalPlanTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/qp/{plan =>
physical}/SerializationTest.java (98%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/qp/sql/DatetimeQueryDataSetUtilsTest.java
rename
server/src/test/java/org/apache/iotdb/db/qp/{strategy/LogicalGeneratorTest.java
=> sql/IoTDBsqlVisitorTest.java} (97%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/qp/utils/DatetimeQueryDataSetUtilsTest.java
copy
server/src/test/java/org/apache/iotdb/db/query/udf/example/{SlidingSizeWindowConstructorTester1.java
=> Max.java} (62%)
copy
server/src/test/java/org/apache/iotdb/db/query/udf/example/{SlidingSizeWindowConstructorTester1.java
=> TerminateTester.java} (73%)
copy
server/src/test/java/org/apache/iotdb/db/query/udf/example/{Multiplier.java =>
ValidateTester.java} (64%)
copy docker/src/main/Dockerfile-0.11.0 => test/e2e/base/docker-compose.yaml
(51%)
create mode 100644 test/e2e/cases/README.md
copy server/file-changelists/TsFileResource-changelist.md =>
test/e2e/cases/cli/README.md (73%)
copy docker/src/main/Dockerfile-0.11.0 => test/e2e/cases/cli/cleanup.sh (51%)
copy docker/src/main/Dockerfile-0.11.0 =>
test/e2e/cases/cli/docker-compose.yaml (51%)
create mode 100644 test/e2e/cases/cli/res/init.sql
copy docker/src/main/Dockerfile-0.11.0 => test/e2e/cases/cli/run.sh (51%)
copy
server/src/main/java/org/apache/iotdb/db/exception/UDFRegistrationException.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/exception/QueryTimeoutRuntimeException.java
(64%)
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/TimeSeriesMetadataReadTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/DefaultDeviceTemplateTest.java
