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/14 14:55:12 UTC
[iotdb] branch NewTsFile updated (3ac9e3a -> 1a99d8e)
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 3ac9e3a optimize some enum class (#2455)
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
add 4589dae merge master
add 1a99d8e fix read old tsfile
No new revisions were added by this update.
Summary of changes:
client-py/src/iotdb/__init__.py => .dockerignore | 3 +
.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 +-
.../apache/iotdb/cluster/RemoteTsFileResource.java | 41 +-
.../iotdb/cluster/config/ClusterConstant.java | 31 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 12 +-
.../cluster/log/manage/CommittedEntryManager.java | 5 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 24 +-
.../log/manage/UnCommittedEntryManager.java | 10 +-
.../apache/iotdb/cluster/server/ClientServer.java | 10 +-
.../apache/iotdb/cluster/server/RaftServer.java | 7 +-
.../cluster/server/heartbeat/HeartbeatThread.java | 8 +-
.../iotdb/cluster/server/member/RaftMember.java | 34 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 9 +-
.../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 | 1 -
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 2 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 2 +-
.../log/catchup/SnapshotCatchUpTaskTest.java | 2 +-
.../cluster/log/manage/RaftLogManagerTest.java | 22 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 2 +-
.../iotdb/cluster/partition/SlotManagerTest.java | 2 +-
.../cluster/partition/SlotPartitionTableTest.java | 2 +-
.../apache/iotdb/cluster/query/BaseQueryTest.java | 10 +-
.../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 ++--
.../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 | 2 +-
.../handlers/caller/ElectionHandlerTest.java | 2 +-
.../handlers/caller/HeartbeatHandlerTest.java | 2 +-
.../handlers/caller/LogCatchUpHandlerTest.java | 2 +-
.../server/heartbeat/HeartbeatThreadTest.java | 5 +-
.../cluster/server/member/DataGroupMemberTest.java | 124 +--
.../iotdb/cluster/server/member/MemberTest.java | 9 +-
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 +
docs/UserGuide/Operation Manual/Administration.md | 2 +
.../DML Data Manipulation Language.md | 155 +++-
.../Operation Manual/UDF User Defined Function.md | 72 ++
docs/UserGuide/Server/Config Manual.md | 18 +
docs/UserGuide/System Tools/CSV Tool.md | 1 +
.../UserGuide/Client/Programming - Native API.md | 14 +
docs/zh/UserGuide/Client/Status Codes.md | 2 +
.../UserGuide/Operation Manual/Administration.md | 2 +
.../DML Data Manipulation Language.md | 156 +++-
.../Operation Manual/UDF User Defined Function.md | 74 ++
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 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 4 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 16 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 15 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 18 +
.../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 | 14 +
server/src/assembly/resources/conf/logback.xml | 1 +
server/src/assembly/resources/sbin/start-server.sh | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 30 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 10 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 37 +-
.../compaction/CompactionMergeTaskPoolManager.java | 2 +-
.../db/engine/compaction/TsFileManagement.java | 16 +
.../level/LevelCompactionTsFileManagement.java | 68 +-
.../no/NoCompactionTsFileManagement.java | 5 +
.../engine/compaction/utils/CompactionLogger.java | 2 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 24 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 46 +-
.../merge/selector/MaxFileMergeFileSelector.java | 11 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 136 ++-
.../db/engine/merge/task/MergeMultiChunkTask.java | 4 +-
.../engine/storagegroup/StorageGroupProcessor.java | 183 ++--
.../db/engine/storagegroup/TsFileProcessor.java | 68 +-
.../db/engine/storagegroup/TsFileResource.java | 383 +++------
.../storagegroup/timeindex/DeviceTimeIndex.java | 308 +++++++
.../storagegroup/timeindex/FileTimeIndex.java | 193 +++++
.../engine/storagegroup/timeindex/ITimeIndex.java | 138 +++
.../timeindex/TimeIndexLevel.java} | 35 +-
.../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 +-
.../query/QueryTimeoutRuntimeException.java | 16 +-
.../org/apache/iotdb/db/metadata/MManager.java | 53 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 77 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 142 +---
.../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 | 2 +
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 8 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 134 ++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 5 +-
.../{ShowOperator.java => KillQueryOperator.java} | 18 +-
.../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 +-
.../sys/{MergePlan.java => KillQueryPlan.java} | 14 +-
.../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 13 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 51 +-
...atusPlan.java => ShowQueryProcesslistPlan.java} | 8 +-
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 56 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 34 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 29 +-
.../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 +-
.../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 +
.../api/customizer/parameter/UDFParameters.java | 6 +-
.../strategy/SlidingTimeWindowAccessStrategy.java | 2 +-
.../db/query/udf/builtin/BuiltinFunction.java | 39 +-
.../apache/iotdb/db/query/udf/builtin/UDTFAbs.java | 126 +--
.../iotdb/db/query/udf/builtin/UDTFAcos.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFAsin.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFAtan.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFBottomK.java | 105 +++
.../iotdb/db/query/udf/builtin/UDTFCeil.java | 9 +-
.../db/query/udf/builtin/UDTFCommonDerivative.java | 62 ++
.../udf/builtin/UDTFCommonValueDifference.java | 60 ++
.../iotdb/db/query/udf/builtin/UDTFContains.java} | 118 ++-
.../apache/iotdb/db/query/udf/builtin/UDTFCos.java | 9 +-
.../udf/builtin/UDTFDegrees.java} | 9 +-
.../db/query/udf/builtin/UDTFDerivative.java} | 45 +-
.../apache/iotdb/db/query/udf/builtin/UDTFExp.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFFloor.java | 9 +-
.../apache/iotdb/db/query/udf/builtin/UDTFLog.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFLog10.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFMatches.java} | 119 ++-
.../iotdb/db/query/udf/builtin/UDTFMath.java} | 178 ++--
.../udf/builtin/UDTFNonNegativeDerivative.java | 63 ++
.../builtin/UDTFNonNegativeValueDifference.java | 61 ++
.../udf/builtin/UDTFRadians.java} | 9 +-
.../iotdb/db/query/udf/builtin/UDTFRound.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFSelectK.java | 156 ++++
.../iotdb/db/query/udf/builtin/UDTFSign.java | 9 +-
.../apache/iotdb/db/query/udf/builtin/UDTFSin.java | 9 +-
.../iotdb/db/query/udf/builtin/UDTFSqrt.java | 9 +-
.../apache/iotdb/db/query/udf/builtin/UDTFTan.java | 9 +-
.../db/query/udf/builtin/UDTFTimeDifference.java} | 40 +-
.../iotdb/db/query/udf/builtin/UDTFTopK.java | 103 +++
.../db/query/udf/builtin/UDTFValueDifference.java} | 37 +-
.../iotdb/db/query/udf/builtin/UDTFValueTrend.java | 73 ++
.../query/udf/service/UDFClassLoaderManager.java | 9 +-
.../query/udf/service/UDFRegistrationService.java | 20 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 5 +-
.../apache/iotdb/db/service/RegisterManager.java | 17 +-
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 946 +++++++++------------
.../db/sync/receiver/load/FileLoaderManager.java | 2 +-
.../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 | 5 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +
.../compaction/LevelCompactionRecoverTest.java | 10 +-
.../engine/storagegroup/TsFileProcessorTest.java | 14 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 1 -
.../iotdb/db/integration/IoTDBClearCacheIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 6 +
.../db/integration/IoTDBFlushQueryMergeIT.java | 2 +-
.../integration/IoTDBGroupByFillWithRangeIT.java | 3 -
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 46 +-
...TDBTracingTest.java => IoTDBKillQueryTest.java} | 55 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 1 -
.../db/integration/IoTDBLevelCompactionIT.java | 4 -
.../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/IoTDBSensorUpdateIT.java | 3 -
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 52 ++
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 31 +-
.../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 | 3 -
.../iotdb/db/query/udf/example/Accumulator.java | 8 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 8 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 8 +-
.../org/apache/iotdb/db/query/udf/example/Max.java | 8 +-
.../iotdb/db/query/udf/example/Multiplier.java | 8 +-
.../SlidingSizeWindowConstructorTester0.java | 9 +-
.../SlidingSizeWindowConstructorTester1.java | 9 +-
.../SlidingTimeWindowConstructionTester.java | 9 +-
.../db/query/udf/example/TerminateTester.java | 8 +-
.../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 | 10 +-
.../db/utils/datastructure/PrecisionTest.java | 22 +-
.../db/writelog/recover/DeviceStringTest.java | 8 +-
server/src/test/resources/logback.xml | 1 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 7 +-
.../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 | 32 +-
.../org/apache/iotdb/session/SessionDataSet.java | 12 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 55 ++
.../iotdb/session/IoTDBSessionComplexIT.java | 3 +-
.../iotdb/session/IoTDBSessionIteratorIT.java | 29 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 130 +++
.../e2e/base/docker-compose.yaml | 46 +-
test/e2e/cases/README.md | 53 ++
.../e2e/cases/cli/README.md | 6 +-
.../e2e/cases/cli/cleanup.sh | 9 +-
.../e2e/cases/cli/docker-compose.yaml | 29 +-
test/e2e/cases/cli/res/init.sql | 26 +
.../sbin/stop-node.sh => test/e2e/cases/cli/run.sh | 35 +-
thrift/src/main/thrift/rpc.thrift | 15 +
...tion.java => QueryTimeoutRuntimeException.java} | 19 +-
.../write/UnSupportedDataTypeException.java | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 165 ++--
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 20 +
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 46 +
.../apache/iotdb/tsfile/write/TsFileWriter.java | 13 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 22 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 5 -
.../read/query/executor/QueryExecutorTest.java | 1 -
.../tsfile/write/DefaultDeviceTemplateTest.java | 110 +++
zeppelin-interpreter/pom.xml | 2 +-
.../apache/zeppelin/iotdb/IoTDBInterpreter.java | 212 +++--
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 108 ++-
326 files changed, 8597 insertions(+), 3565 deletions(-)
copy client-py/src/iotdb/__init__.py => .dockerignore (97%)
create mode 100644 .github/workflows/e2e.yml
create mode 100644 cli/src/main/java/org/apache/iotdb/cli/utils/IoTPrinter.java
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/engine/{compaction/CompactionStrategy.java => storagegroup/timeindex/TimeIndexLevel.java} (52%)
copy server/src/main/java/org/apache/iotdb/db/exception/{LoadEmptyFileException.java => QueryIdNotExsitException.java} (79%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/write/WriteProcessException.java => server/src/main/java/org/apache/iotdb/db/exception/query/QueryTimeoutRuntimeException.java (65%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{ShowOperator.java => KillQueryOperator.java} (72%)
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/{MergePlan.java => KillQueryPlan.java} (83%)
copy server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowMergeStatusPlan.java => ShowQueryProcesslistPlan.java} (84%)
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
copy example/udf/src/main/java/org/apache/iotdb/udf/UDTFExample.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAbs.java (53%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAcos.java (83%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAsin.java (83%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAtan.java (83%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFBottomK.java
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFCeil.java (83%)
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/Multiplier.java => main/java/org/apache/iotdb/db/query/udf/builtin/UDTFContains.java} (69%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFCos.java (83%)
copy server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/ShowMergeStatusPlan.java => query/udf/builtin/UDTFDegrees.java} (82%)
copy server/src/{test/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java => main/java/org/apache/iotdb/db/query/udf/builtin/UDTFDerivative.java} (62%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFExp.java (83%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFFloor.java (82%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFLog.java (83%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFLog10.java (82%)
copy server/src/{test/java/org/apache/iotdb/db/query/udf/example/Multiplier.java => main/java/org/apache/iotdb/db/query/udf/builtin/UDTFMatches.java} (69%)
copy server/src/{test/java/org/apache/iotdb/db/query/udf/example/Adder.java => main/java/org/apache/iotdb/db/query/udf/builtin/UDTFMath.java} (53%)
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/{qp/physical/sys/ShowMergeStatusPlan.java => query/udf/builtin/UDTFRadians.java} (82%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFRound.java (83%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFSelectK.java
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFSign.java (82%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFSin.java (83%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFSqrt.java (83%)
copy cluster/src/test/java/org/apache/iotdb/cluster/common/TestException.java => server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFTan.java (83%)
copy server/src/{test/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java => main/java/org/apache/iotdb/db/query/udf/builtin/UDTFTimeDifference.java} (68%)
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/ValidateTester.java => main/java/org/apache/iotdb/db/query/udf/builtin/UDTFValueDifference.java} (60%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFValueTrend.java
copy server/src/test/java/org/apache/iotdb/db/integration/{IoTDBTracingTest.java => IoTDBKillQueryTest.java} (54%)
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 cluster/src/assembly/resources/sbin/stop-node.sh => test/e2e/base/docker-compose.yaml (54%)
create mode 100644 test/e2e/cases/README.md
copy docs/zh/SystemDesign/QueryEngine/PlanExecutor.md => test/e2e/cases/cli/README.md (88%)
copy server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter => test/e2e/cases/cli/cleanup.sh (89%)
copy server/src/assembly/resources/tools/stop-sync-client.sh => test/e2e/cases/cli/docker-compose.yaml (67%)
mode change 100755 => 100644
create mode 100644 test/e2e/cases/cli/res/init.sql
copy cluster/src/assembly/resources/sbin/stop-node.sh => test/e2e/cases/cli/run.sh (55%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/{NotImplementedException.java => QueryTimeoutRuntimeException.java} (68%)
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/write/DefaultDeviceTemplateTest.java