This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch xianyi
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 9ccbfeb dataGenerator (#4468)
new 7a3b33c add taskId to InsertTabletPlanTask
new 1aebcaa fix concurrent select-into
add aaadc5c Fix exception when getting Statistics of aligned time series
in memory (#4430)
add 7ff968c [IOTDB-2027] Rollback invalid entry after wal writing failure
(#4424)
add fc31d50 [IOTDB-1926]TsFile API supports query on aligned timeseries
(#4390)
add 9016d74 [IOTDB-1961] Cluster query memory leak (#4343)
add 1eb9e0e Refactor the todf() function of client-py to improve
performance (#4242)
add 049c421 [IOTDB-1945] Support raw data query with value filter in new
vector (#4433)
add 05158d1 add javadoc for cluster (#4417)
add d9d8733 [IOTDB-2036] RestApiServiceImpl accesses to
BasicServiceProvider (#4434)
add 441d6b7 [IOTDB-1931] Adapt tree structrued Template with MManager
(#4391)
add 8030147 [IOTDB-2006] avoid NPE while while calling the equals method
of Object (#4439)
add fd145d6 [IOTDB-2038] MqttService accesses to BasicServiceProvider
(#4440)
add 98be7dd Bump nodeVersion in site deploy to v16.9.1 to support build
website on ARM mac (#4442)
add f8c18ac [IOTDB-2030] Add IWritableMemChunkGroup Interface to unify
the map in memtable (#4412)
add ab32867 [IOTDB-2016][metric] Fix ClassCastException when create new
metric types (#4425)
add 2f62994 Remind user to avoid frequently using flush command in client
(#4445)
add c6744c5 [IOTDB-2047] Fix Partial insert NPE for aligned and
non-aligned series (#4444)
add 49e5b2f [IOTDB-1951] Support aggregation query without value filter
in new vector (#4441)
add c4d73e8 [IOTDB-1974] Support Last Query for Aligned Timeseries (#4447)
add bdebc92 Use statistics of time column in canUseCurrent*Statistics()
method in AlignedSeriesAggregateReader (#4451)
add 046ac2d [IOTDB-2031] Fix incorrect result of descending query with
multiple time_partitions (#4432)
add 14505c1 [IOTDB-2031] Fix incorrect result of descending query with
value filter in cluster (#4431)
add 1f853f1 Use safer SQL query to guarantee column order
add a3cd374 [IOTDB-2056] Fix totalPointsNumThreshold calculation error
causes too many tsfile flushed (#4461)
new 30ac72e merge master
new 47c0584 add builtin udf en
new 4fd32d6 fix udf bug
new 7b816c0 fix conflicts
new 8358b32 change config
The 7 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:
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 4 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 10 +-
client-py/SessionExample.py | 4 +-
client-py/iotdb/utils/BitMap.py | 3 +-
client-py/iotdb/utils/IoTDBConstants.py | 1 +
client-py/iotdb/utils/IoTDBRpcDataSet.py | 138 ++++-
client-py/iotdb/utils/SessionDataSet.py | 26 +-
client-py/iotdb/utils/Tablet.py | 10 +-
client-py/tests/tablet_performance_comparison.py | 129 ++--
client-py/tests/test_dataframe.py | 29 +-
client-py/tests/test_todf.py | 216 +++++++
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 4 +
.../log/snapshot/PullSnapshotTaskDescriptor.java | 2 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 8 +-
.../cluster/partition/NodeAdditionResult.java | 4 +-
.../iotdb/cluster/partition/NodeRemovalResult.java | 4 +-
.../iotdb/cluster/partition/PartitionGroup.java | 33 +-
.../iotdb/cluster/partition/PartitionTable.java | 6 +-
.../partition/balancer/DefaultSlotBalancer.java | 6 +-
.../cluster/partition/balancer/SlotBalancer.java | 4 +-
.../iotdb/cluster/partition/slot/SlotManager.java | 2 +-
.../partition/slot/SlotNodeAdditionResult.java | 2 +-
.../cluster/partition/slot/SlotPartitionTable.java | 48 +-
.../iotdb/cluster/partition/slot/SlotStrategy.java | 2 +-
.../partition/slot/SlotTimePartitionFilter.java | 3 +-
.../cluster/query/ClusterDataQueryExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 6 +-
.../cluster/query/aggregate/ClusterAggregator.java | 3 +-
.../cluster/query/fill/ClusterPreviousFill.java | 2 +-
.../query/last/ClusterLastQueryExecutor.java | 2 +-
.../manage/ClusterSessionManager.java} | 101 ++--
.../cluster/query/reader/ClusterReaderFactory.java | 13 +-
....java => AssignPathAscPriorityMergeReader.java} | 37 +-
...java => AssignPathDescPriorityMergeReader.java} | 37 +-
.../reader/mult/AssignPathManagedMergeReader.java | 43 +-
.../reader/mult/AssignPathPriorityMergeReader.java | 66 ---
.../mult/IAssignPathPriorityMergeReader.java | 36 +-
.../{MultEmptyReader.java => MultElement.java} | 37 +-
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 79 +--
.../cluster/server/PullSnapshotHintService.java | 2 +-
.../iotdb/cluster/server/StoppedMemberManager.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 7 +-
.../cluster/server/member/MetaGroupMember.java | 4 +-
.../iotdb/cluster/server/member/RaftMember.java | 2 +-
.../cluster/server/service/DataGroupEngine.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 2 +-
.../cluster/utils/nodetool/function/Slot.java | 2 +-
.../cluster/partition/SlotPartitionTableTest.java | 2 +-
.../mult/AssignPathManagedMergeReaderTest.java | 3 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 2 +-
.../iotdb/cluster/server/member/BaseMember.java | 4 +-
.../cluster/server/member/DataGroupMemberTest.java | 13 +-
.../cluster/server/member/RaftMemberTest.java | 4 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 38 +-
.../IoTDB-SQL-Language/Maintenance-Command.md | 4 +
.../UserGuide/API/Programming-Java-Native-API.md | 23 +-
.../IoTDB-SQL-Language/Maintenance-Command.md | 3 +
.../java/org/apache/iotdb/flink/TsFileUtils.java | 4 +-
example/session/pom.xml | 99 ++++
.../iotdb/AlignedTimeseriesSessionExample.java | 658 ---------------------
.../org/apache/iotdb/DataMigrationExample.java | 187 ------
.../iotdb/HybridTimeseriesSessionExample.java | 125 ----
.../org/apache/iotdb/SessionConcurrentExample.java | 199 -------
.../main/java/org/apache/iotdb/SessionExample.java | 277 +++------
.../java/org/apache/iotdb/SessionPoolExample.java | 128 ----
.../main/java/org/apache/iotdb/TabletExample.java | 195 ------
.../main/java/org/apache/iotdb/TriggerExample.java | 139 -----
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 8 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 2 +-
.../iotdb/flink/tsfile/TsFileInputFormat.java | 6 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 4 +-
.../apache/iotdb/generator/GeneratorEntrance.java | 11 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 2 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 58 +-
.../dropwizard/DropwizardMetricManager.java | 134 +++--
.../dropwizard/type/DropwizardHistogram.java | 5 -
.../dropwizard/DropwizardMetricManagerTest.java | 15 +-
.../org/apache/iotdb/metrics/MetricManager.java | 6 +-
.../iotdb/metrics/impl/DoNothingHistogram.java | 4 -
.../org/apache/iotdb/metrics/type/Histogram.java | 3 -
.../micrometer/MicrometerMetricManager.java | 162 +++--
.../micrometer/type/MicrometerHistogram.java | 5 -
.../micrometer/MicrometerMetricManagerTest.java} | 38 +-
.../resources/conf/iotdb-engine.properties | 9 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 8 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 8 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 4 +-
.../iotdb/db/engine/cache/AccountableString.java | 64 --
.../db/engine/compaction/TsFileIdentifier.java | 2 +-
.../compaction/cross/CrossCompactionStrategy.java | 2 +-
.../compaction/inner/InnerCompactionStrategy.java | 2 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 5 +-
.../iotdb/db/engine/flush/NotifyFlushMemTable.java | 12 -
.../iotdb/db/engine/memtable/AbstractMemTable.java | 240 ++++----
.../engine/memtable/AlignedWritableMemChunk.java | 123 ++--
.../memtable/AlignedWritableMemChunkGroup.java | 81 +++
.../apache/iotdb/db/engine/memtable/IMemTable.java | 9 +-
.../db/engine/memtable/IWritableMemChunk.java | 11 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 42 +-
.../db/engine/memtable/PrimitiveMemTable.java | 17 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 18 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 112 ++++
.../querycontext/AlignedReadOnlyMemChunk.java | 4 +-
.../engine/storagegroup/StorageGroupProcessor.java | 15 +-
.../db/engine/storagegroup/TsFileProcessor.java | 29 +-
...tion.java => TemplateImcompatibeException.java} | 18 +-
.../org/apache/iotdb/db/metadata/MManager.java | 71 ++-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 12 -
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 2 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 12 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 3 +
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 259 ++++++--
.../db/metadata/mtree/traverser/Traverser.java | 115 ++--
.../traverser/collector/MeasurementCollector.java | 29 +
.../apache/iotdb/db/metadata/path/AlignedPath.java | 33 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 9 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 4 +-
.../iotdb/db/metadata/template/Template.java | 113 ++--
.../db/metadata/template/TemplateManager.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 2 +-
.../iotdb/db/metrics/server/ServerArgument.java | 6 +-
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 84 ++-
.../iotdb/db/qp/logical/crud/InOperator.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 22 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 2 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 26 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 2 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 2 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 2 +-
.../db/qp/physical/sys/AppendTemplatePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 2 +-
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 2 +-
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 2 +-
.../qp/physical/sys/CreateContinuousQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 2 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 2 +-
.../db/qp/physical/sys/CreateTemplatePlan.java | 4 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 2 +-
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 2 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 2 +-
.../qp/physical/sys/DropContinuousQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DropIndexPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 2 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 2 +-
.../db/qp/physical/sys/PruneTemplatePlan.java | 2 +-
.../db/qp/physical/sys/SetStorageGroupPlan.java | 2 +-
.../db/qp/physical/sys/SetSystemModePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 2 +-
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 2 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 8 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 12 +-
.../db/query/aggregation/impl/CountAggrResult.java | 1 +
.../iotdb/db/query/control/SessionManager.java | 2 +-
.../db/query/control/SessionTimeoutManager.java | 17 +-
.../db/query/executor/AggregationExecutor.java | 34 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 6 +-
.../db/query/executor/fill/LastPointReader.java | 1 +
...ChunkLoader.java => MemAlignedChunkLoader.java} | 13 +-
...ChunkReader.java => MemAlignedChunkReader.java} | 14 +-
...emPageReader.java => MemAlignedPageReader.java} | 51 +-
...ader.java => AlignedSeriesAggregateReader.java} | 36 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 49 +-
.../reader/series/SeriesReaderByTimestamp.java | 5 +-
.../db/query/udf/builtin/BuiltinFunction.java | 2 +-
.../iotdb/db/query/udf/builtin/UDTFCast.java | 2 +-
.../apache/iotdb/db/query/udf/builtin}/UDTFEn.java | 2 +-
.../db/query/udf/core/executor/UDTFExecutor.java | 1 +
.../query/udf/core/layer/RawQueryInputLayer.java | 1 +
...nputColumnSingleReferenceIntermediateLayer.java | 4 +
.../iotdb/db/rest/filter/AuthorizationFilter.java | 2 +-
.../db/rest/handler/AuthorizationHandler.java | 20 +-
.../iotdb/db/rest/impl/RestApiServiceImpl.java | 59 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 88 ++-
.../db/service/basic/BasicServiceProvider.java | 21 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 4 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 2 +-
.../iotdb/db/tools/vis/TsFileExtractVisdata.java | 2 +-
.../db/tools/watermark/WatermarkDetector.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 31 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 2 -
.../iotdb/db/writelog/recover/LogReplayer.java | 25 +-
.../org/apache/iotdb/db/constant/TestConstant.java | 3 +
.../engine/compaction/cross/MergeOverLapTest.java | 2 +
.../inner/InnerSpaceCompactionUtilsTest.java | 4 +-
.../db/engine/memtable/MemTableTestUtils.java | 6 +-
.../db/engine/memtable/MemtableBenchmark.java | 7 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 58 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 9 +-
... => IoTDBAggregationWithoutValueFilter2IT.java} | 13 +-
.../IoTDBAggregationWithoutValueFilterIT.java | 444 ++++++++++++++
...regationWithoutValueFilterWithDeletion2IT.java} | 16 +-
...ggregationWithoutValueFilterWithDeletionIT.java | 447 ++++++++++++++
...tValueFilter2IT.java => IoTDBLastQuery2IT.java} | 11 +-
.../db/integration/aligned/IoTDBLastQueryIT.java | 374 ++++++++++++
...2IT.java => IoTDBLastQueryWithDeletion2IT.java} | 14 +-
.../aligned/IoTDBLastQueryWithDeletionIT.java | 380 ++++++++++++
...java => IoTDBLastQueryWithoutLastCache2IT.java} | 14 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 379 ++++++++++++
...BLastQueryWithoutLastCacheWithDeletion2IT.java} | 21 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 384 ++++++++++++
...T.java => IoTDBRawQueryWithValueFilter2IT.java} | 11 +-
...IT.java => IoTDBRawQueryWithValueFilterIT.java} | 398 ++++++++-----
...TDBRawQueryWithValueFilterWithDeletion2IT.java} | 13 +-
...oTDBRawQueryWithValueFilterWithDeletionIT.java} | 385 ++++++++----
.../IoTDBRawQueryWithoutValueFilter2IT.java | 8 +-
.../aligned/IoTDBRawQueryWithoutValueFilterIT.java | 8 +-
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 8 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 8 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 222 +++++--
.../org/apache/iotdb/db/metadata/TemplateTest.java | 4 +-
.../apache/iotdb/db/mqtt/PublishHandlerTest.java | 75 ++-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 77 ++-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 137 +++++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 61 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 10 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 6 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 18 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../org/apache/iotdb/session/ClusterSession.java | 37 +-
.../java/org/apache/iotdb/session/Session.java | 96 +--
.../org/apache/iotdb/session/pool/SessionPool.java | 51 --
.../apache/iotdb/session/template/Template.java | 2 +-
.../session/IoTDBSessionDisableMemControlIT.java | 205 +++++++
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 268 +++++++++
.../session/IoTDBSessionVectorABDeviceIT.java | 3 +
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 75 +++
.../java/org/apache/iotdb/session/SessionTest.java | 93 ++-
.../apache/iotdb/session/template/TemplateUT.java | 56 +-
site/pom.xml | 2 +-
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 4 +-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 6 +-
thrift/src/main/thrift/rpc.thrift | 7 +-
.../iotdb/tsfile/common/cache/Accountable.java | 26 -
.../tsfile/file/metadata/AlignedChunkMetadata.java | 4 +
.../file/metadata/AlignedTimeSeriesMetadata.java | 4 +
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 14 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 13 +-
.../{ReadOnlyTsFile.java => TsFileReader.java} | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 190 ++++--
.../apache/iotdb/tsfile/read/common/BatchData.java | 16 +
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 13 +-
.../org/apache/iotdb/tsfile/read/common/Field.java | 26 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 2 +-
.../read/controller/MetadataQuerierByFileImpl.java | 87 +--
.../iotdb/tsfile/read/filter/TimeFilter.java | 11 +
.../iotdb/tsfile/read/filter/operator/Like.java | 6 +-
.../query/dataset/DataSetWithTimeGenerator.java | 15 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 24 +-
.../tsfile/read/reader/IAlignedPageReader.java | 13 +-
.../read/reader/chunk/AlignedChunkReader.java | 6 +-
...amp.java => AlignedChunkReaderByTimestamp.java} | 15 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 9 +-
.../reader/series/AbstractFileSeriesReader.java | 4 +-
.../read/reader/series/FileSeriesReader.java | 18 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 28 +-
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 2 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 21 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 84 ++-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 44 +-
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 28 +
.../chunk/NonAlignedChunkGroupWriterImpl.java | 40 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 16 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 4 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 241 --------
.../org/apache/iotdb/tsfile/read/ReadTest.java | 4 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 4 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 477 +++++++++++++++
.../tsfile/read/TsFileSequenceReaderTest.java | 4 +-
.../read/query/timegenerator/ReadWriteTest.java | 6 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 6 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 6 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 122 ++++
.../tsfile/write/DefaultSchemaTemplateTest.java | 4 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 6 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 6 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 266 ++++++---
.../iotdb/tsfile/write/TsFileWriterTest.java | 14 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 8 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 15 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 3 +-
304 files changed, 8177 insertions(+), 4764 deletions(-)
create mode 100644 client-py/tests/test_todf.py
copy
cluster/src/main/java/org/apache/iotdb/cluster/{server/ClusterTSServiceImpl.java
=> query/manage/ClusterSessionManager.java} (59%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/{MultEmptyReader.java
=> AssignPathAscPriorityMergeReader.java} (58%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/{MultEmptyReader.java
=> AssignPathDescPriorityMergeReader.java} (58%)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathPriorityMergeReader.java
copy
server/src/main/java/org/apache/iotdb/db/query/reader/universal/DescPriorityMergeReader.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IAssignPathPriorityMergeReader.java
(52%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/{MultEmptyReader.java
=> MultElement.java} (55%)
delete mode 100644
example/session/src/main/java/org/apache/iotdb/AlignedTimeseriesSessionExample.java
delete mode 100644
example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java
delete mode 100644
example/session/src/main/java/org/apache/iotdb/HybridTimeseriesSessionExample.java
delete mode 100644
example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java
delete mode 100644
example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
delete mode 100644
example/session/src/main/java/org/apache/iotdb/TabletExample.java
delete mode 100644
example/session/src/main/java/org/apache/iotdb/TriggerExample.java
copy
metrics/{dropwizard-metrics/src/test/java/org/apache/iotdb/metrics/dropwizard/PrometheusRunTest.java
=>
micrometer-metrics/src/test/java/org/apache/iotdb/metrics/micrometer/MicrometerMetricManagerTest.java}
(52%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/cache/AccountableString.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/memtable/AlignedWritableMemChunkGroup.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/partition/balancer/SlotBalancer.java
=>
server/src/main/java/org/apache/iotdb/db/engine/memtable/IWritableMemChunkGroup.java
(57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/memtable/WritableMemChunkGroup.java
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{IllegalPathException.java
=> TemplateImcompatibeException.java} (63%)
copy
server/src/main/java/org/apache/iotdb/db/query/reader/chunk/{MemChunkLoader.java
=> MemAlignedChunkLoader.java} (80%)
copy
server/src/main/java/org/apache/iotdb/db/query/reader/chunk/{MemChunkReader.java
=> MemAlignedChunkReader.java} (86%)
copy
server/src/main/java/org/apache/iotdb/db/query/reader/chunk/{MemPageReader.java
=> MemAlignedPageReader.java} (56%)
rename
server/src/main/java/org/apache/iotdb/db/query/reader/series/{VectorSeriesAggregateReader.java
=> AlignedSeriesAggregateReader.java} (78%)
copy {example/udf/src/main/java/org/apache/iotdb/udf =>
server/src/main/java/org/apache/iotdb/db/query/udf/builtin}/UDTFEn.java (97%)
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilter2IT.java
=> IoTDBAggregationWithoutValueFilter2IT.java} (84%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
=> IoTDBAggregationWithoutValueFilterWithDeletion2IT.java} (85%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterWithDeletionIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilter2IT.java
=> IoTDBLastQuery2IT.java} (84%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
=> IoTDBLastQueryWithDeletion2IT.java} (86%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletionIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilter2IT.java
=> IoTDBLastQueryWithoutLastCache2IT.java} (79%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java} (79%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilter2IT.java
=> IoTDBRawQueryWithValueFilter2IT.java} (84%)
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilterIT.java
=> IoTDBRawQueryWithValueFilterIT.java} (64%)
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
=> IoTDBRawQueryWithValueFilterWithDeletion2IT.java} (86%)
copy
server/src/test/java/org/apache/iotdb/db/integration/aligned/{IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
=> IoTDBRawQueryWithValueFilterWithDeletionIT.java} (62%)
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionDisableMemControlIT.java
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/common/cache/Accountable.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/read/{ReadOnlyTsFile.java
=> TsFileReader.java} (94%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngineMBean.java
=>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/IAlignedPageReader.java
(78%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/{ChunkReaderByTimestamp.java
=> AlignedChunkReaderByTimestamp.java} (71%)
delete mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadOnlyTsFileTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/TsFileReaderTest.java
