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 2022/04/06 03:01:06 UTC
[iotdb] branch InsertTabletNode updated (c921a085f4 -> f599facb6e)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch InsertTabletNode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c921a085f4 fix compile
add 540473054a Rename SchemaEngine to LocalSchemaProcessor and Rename SchemaRegionManager to SchemaEngine (#5359)
add 0f21cef109 Fix typos in mpp.thrift (#5360)
add 27f2b96496 [IOTDB-2713] Generate Analysis for query statement (#5343)
add 4a70fba534 [IOTDB-2658] Generate logical plan for query statement (#5356)
add bcd53d7435 [IOTDB-2810] Design and implementation of TsBlock and its builder (#5362)
add 0acb90666f Demo for integration of ConfigNode and ratis-consensus (#5361)
add b017eae34c [IOTDB-2784] Add unit tests for FragmentInstanceTask scheduling (#5337)
add 4050490b48 Connect the Query Plan stage from SQL to DistributionPlan with UT and mock interfaces (#5364)
add 9c5fdd5493 [IOTDB-2768] Add UT for SeriesScanOperator, TimeJoinOperator and LimitOperator (#5365)
add bfe585dc3c Add getSchedulePriority for FragmentInstanceManager (#5371)
add 96f919a171 [IOTDB-2820]Update Userguide SQL about Trigger (#5372)
add 938c1f19df Demo of ConfigNode (#5368)
add 7b307e76bb Fix NoClassDefFound CI error (#5370)
add 28b9e822d2 [IOTDB-2824] fix stop-server.sh that wrongly kill process (#5378)
add 534475b268 Fix cpp client tests cannot pass with latest Windows environment (windows server 2022) (#5375)
add 1ffad89199 [IOTDB-2828] Update system_version in system.properties after upgrading finished (#5385)
add ca53f81159 Implement SchemaTree Search (#5383)
add cec372afef Add interface in ConfigIService (#5386)
add 63b46689f8 Add isLeaderOf to Consensus (#5377)
add fcc4bf2746 Update python client doc and code for NumpyTablet (#5395)
add c414b81813 Bump jjwt-jackson from 0.10.7 to 0.10.8 (#5394)
add fdfee46676 Bump httpcore from 4.4.13 to 4.4.15 (#5391)
add c96cfa711d [IOTDB-2684] refactoring confignode architecture and schema partition assign (#5374)
add d9fb0c1d02 [IOTDB-2819][metrics] modify session to session pool. (#5369)
add f144d19c57 [IOTDB-2836] Fix ErrorHandlingUtils exception stacktrace logging (#5399)
add be883fd8cc [IOTDB-2818] Fix exception occurs when submitting compaction task to global queue (#5384)
add 55566b6eb6 refactor count node by level (#5398)
add 1f7361c7f3 [IOTDB-2650] Tablet supports adding String value (#5382)
add d00a3df757 [IOTDB-2833] Add readme to consensus (#5396)
add 6b073731f2 Add c rest client example (#5397)
add 566fa07497 fix bug in ratis consensus test (#5404)
add d8a0ac45a4 Unify class definitions of common concepts and move them into node-commons package (#5400)
add ee6e7700cf [IOTDB-2748] Writing statement and writing process of coordinator (#5355)
add 90e381d7c8 [IOTDB-2811] Fix compaction exception handle failure cause by deletion of storage group (#5363)
add 2c85f9cda2 [IOTDB-2839] Add Python client CI (#5407)
add fbfb3ebe2c [IOTDB-2843] remove unused jna dependency in cli (#5410)
add 519122ecca fix conflicts
add f599facb6e simplify time partition check logic
No new revisions were added by this update.
Summary of changes:
.github/workflows/{client.yml => client-cpp.yml} | 10 +-
.github/workflows/client-python.yml | 63 ++
cli/pom.xml | 2 +
client-py/README.md | 277 +++++-
client-py/SessionAlignedTimeseriesTest.py | 280 ------
client-py/SessionExample.py | 2 +-
client-py/SessionTest.py | 336 --------
client-py/requirements_dev.txt | 2 +-
client-py/tests/test_aligned_timeseries.py | 279 ++++++
client-py/tests/test_dataframe.py | 6 +-
client-py/tests/test_session.py | 335 ++++++++
client-py/tests/test_todf.py | 12 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 8 +-
.../iotdb/cluster/coordinator/Coordinator.java | 10 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 8 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 6 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 2 +-
.../log/manage/PartitionedSnapshotLogManager.java | 4 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 4 +-
.../{CSchemaEngine.java => CSchemaProcessor.java} | 20 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 10 +-
.../iotdb/cluster/partition/PartitionTable.java | 4 +-
.../cluster/query/ClusterPhysicalGenerator.java | 8 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 22 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 17 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 31 +-
.../iotdb/cluster/query/filter/SlotSgFilter.java | 2 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 4 +-
.../cluster/server/member/DataGroupMember.java | 6 +-
.../cluster/server/member/MetaGroupMember.java | 2 +-
.../cluster/server/service/DataAsyncService.java | 15 +-
.../cluster/server/service/DataSyncService.java | 12 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 2 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../log/applier/AsyncDataLogApplierTest.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 13 +-
.../cluster/log/applier/MetaLogApplierTest.java | 6 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 2 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 22 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 4 +-
.../log/snapshot/PartitionedSnapshotTest.java | 9 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 5 +-
...eWhiteBox.java => SchemaProcessorWhiteBox.java} | 20 +-
.../cluster/partition/SlotPartitionTableTest.java | 26 +-
.../cluster/query/ClusterPlanExecutorTest.java | 2 +-
.../clusterinfo/ClusterInfoServiceImplTest.java | 4 +-
.../iotdb/cluster/server/member/BaseMember.java | 10 +-
.../cluster/server/member/DataGroupMemberTest.java | 6 +-
.../cluster/server/member/MetaGroupMemberTest.java | 22 +-
confignode/pom.xml | 2 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfCheck.java | 28 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../consensus/response/DataNodesInfoDataSet.java | 12 +-
...chemaDataSet.java => DataPartitionDataSet.java} | 18 +-
.../consensus/response/SchemaPartitionDataSet.java | 82 ++
.../response/StorageGroupSchemaDataSet.java | 8 +-
.../iotdb/confignode/manager/ConfigManager.java | 214 +++--
.../{ConfigManager.java => ConsensusManager.java} | 32 +-
.../iotdb/confignode/manager/DataNodeManager.java | 169 ++++
.../apache/iotdb/confignode/manager/Manager.java | 119 +++
.../iotdb/confignode/manager/PartitionManager.java | 145 ++++
.../iotdb/confignode/manager/RegionManager.java | 152 ++++
...{DataPartitionInfo.java => DataRegionInfo.java} | 46 +-
.../iotdb/confignode/partition/PartitionTable.java | 185 ----
...emaPartitionInfo.java => SchemaRegionInfo.java} | 41 +-
.../persistence/DataNodeInfoPersistence.java | 186 ++++
.../persistence/PartitionInfoPersistence.java | 157 ++++
.../persistence/RegionInfoPersistence.java | 198 +++++
.../iotdb/confignode/physical/PhysicalPlan.java | 14 +
.../confignode/physical/PhysicalPlanType.java | 6 +-
.../confignode/physical/sys/DataPartitionPlan.java | 78 ++
.../physical/sys/RegisterDataNodePlan.java | 12 +-
.../physical/sys/SchemaPartitionPlan.java | 97 +++
.../physical/sys/SetStorageGroupPlan.java | 30 +
.../confignode/service/balancer/LoadBalancer.java | 12 -
.../confignode/service/executor/PlanExecutor.java | 32 +-
.../server/ConfigNodeRPCServerProcessor.java | 101 ++-
.../confignode/util/SerializeDeserializeUtil.java | 242 ++++++
.../confignode/consensus/RatisConsensusDemo.java | 136 +++
.../hash/DeviceGroupHashExecutorManualTest.java | 4 +-
.../server/ConfigNodeRPCServerProcessorTest.java | 158 +++-
.../utils/SerializeDeserializeUtilTest.java | 90 ++
consensus/README.md | 123 +++
consensus/pom.xml | 6 +
.../org/apache/iotdb/consensus/IConsensus.java | 4 +-
.../iotdb/consensus/common/ConsensusGroup.java | 2 +
.../iotdb/consensus/common}/ConsensusType.java | 2 +-
.../org/apache/iotdb/consensus/common/Peer.java | 3 +
.../ConsensusGroupAlreadyExistException.java | 2 +-
.../exception/ConsensusGroupNotExistException.java | 2 +-
.../PeerAlreadyInConsensusGroupException.java | 2 +-
.../PeerNotInConsensusGroupException.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 68 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 25 +-
.../consensus/standalone/StandAloneConsensus.java | 7 +-
.../consensus/statemachine/IStateMachine.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 41 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 6 +-
.../standalone/StandAloneConsensusTest.java | 6 +-
.../UserGuide/API/Programming-Python-Native-API.md | 19 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 1 +
docs/UserGuide/Process-Data/Alerting.md | 2 +-
.../UserGuide/API/Programming-Python-Native-API.md | 17 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 1 +
docs/zh/UserGuide/Process-Data/Alerting.md | 2 +-
example/rest-client-c-example/README.md | 111 +++
example/rest-client-c-example/base64.c | 100 +++
.../rest-client-c-example/base64.h | 14 +-
example/rest-client-c-example/main.c | 124 +++
.../iotdb/db/integration/IoTDBArithmeticIT.java | 18 +-
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 14 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 70 +-
.../integration/IoTDBManageTsFileResourceIT.java | 8 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 12 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 18 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 8 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 26 +-
.../db/integration/IoTDBTriggerManagementIT.java | 8 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 6 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 64 +-
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 4 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 46 +-
.../metrics/dropwizard/reporter/IoTDBReporter.java | 40 +-
.../main/assembly/resources/conf/iotdb-metric.yml | 1 +
.../apache/iotdb/metrics/config/MetricConfig.java | 10 +
.../interface/src/test/resources/iotdb-metric.yml | 1 +
.../micrometer/reporter/IoTDBMeterRegistry.java | 32 +-
node-commons/pom.xml | 2 +-
.../apache/iotdb/commons/cluster}/Endpoint.java | 26 +-
.../iotdb/commons/consensus}/ConsensusGroupId.java | 27 +-
.../apache/iotdb/commons/consensus}/GroupType.java | 2 +-
.../iotdb/commons/partition/DataNodeLocation.java | 38 +-
.../{DataPartitionInfo.java => DataPartition.java} | 40 +-
.../commons/partition/DataPartitionQueryParam.java | 20 +-
.../iotdb/commons/partition/DataRegionId.java | 39 -
.../commons/partition/DataRegionReplicaSet.java | 53 --
.../iotdb/commons/partition/PartitionInfo.java | 20 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 89 ++
.../iotdb/commons/partition/SchemaPartition.java | 92 ++
.../commons/partition/SchemaPartitionInfo.java | 36 -
.../iotdb/commons/partition/SchemaRegionId.java | 54 --
.../commons/partition/SchemaRegionReplicaSet.java | 44 -
...DeviceGroupId.java => SeriesPartitionSlot.java} | 8 +-
...TimePartitionId.java => TimePartitionSlot.java} | 2 +-
pom.xml | 12 +-
server/pom.xml | 4 +-
server/src/assembly/resources/sbin/stop-server.sh | 13 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 6 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 3 +-
.../iotdb/db/consensus/ConsensusExample.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 109 ++-
.../engine/compaction/CompactionTaskManager.java | 95 ++-
.../db/engine/compaction/CompactionUtils.java | 4 +-
.../cross/AbstractCrossSpaceCompactionTask.java | 9 +
.../manage/CrossSpaceCompactionResource.java | 3 +-
.../task/RewriteCrossSpaceCompactionTask.java | 4 +
.../inner/AbstractInnerSpaceCompactionTask.java | 9 +
.../sizetiered/SizeTieredCompactionSelector.java | 4 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 6 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 2 +-
.../compaction/task/AbstractCompactionTask.java | 20 +-
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 4 +
.../db/engine/storagegroup/TsFileResourceList.java | 5 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 94 +-
.../virtualSg/StorageGroupManager.java | 14 +-
.../service/TriggerRegistrationService.java | 2 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 6 +-
.../iotdb/db/metadata/LocalConfigManager.java | 97 ++-
.../db/metadata/LocalSchemaPartitionTable.java | 30 +-
...SchemaEngine.java => LocalSchemaProcessor.java} | 63 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 10 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 6 +-
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 23 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 6 +-
.../db/metadata/mtree/traverser/Traverser.java | 10 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../mtree/traverser/counter/MNodeLevelCounter.java | 18 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 5 +
...{SchemaRegionManager.java => SchemaEngine.java} | 26 +-
.../db/metadata/schemaregion/SchemaRegion.java | 19 +-
.../storagegroup/IStorageGroupSchemaManager.java | 22 +-
.../storagegroup/StorageGroupSchemaManager.java | 15 +-
.../iotdb/db/metadata/template/Template.java | 18 +-
.../db/metadata/template/TemplateManager.java | 6 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 62 +-
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 4 +-
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 2 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 2 +-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 2 +-
.../db/mpp/common/schematree/PathPatternNode.java | 68 +-
.../db/mpp/common/schematree/PathPatternTree.java | 117 ++-
.../db/mpp/common/schematree/SchemaEntityNode.java | 43 +
.../mpp/common/schematree/SchemaInternalNode.java | 32 +-
.../common/schematree/SchemaMeasurementNode.java | 29 +-
.../iotdb/db/mpp/common/schematree/SchemaNode.java | 44 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 25 +-
.../mpp/common/schematree/SchemaTreeVisitor.java | 235 +++++
.../db/mpp/execution/FragmentInstanceContext.java | 4 +
.../iotdb/db/mpp/execution/QueryExecution.java | 18 +-
.../execution/scheduler/StandaloneScheduler.java | 4 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 2 +-
.../db/mpp/operator/process/AggregateOperator.java | 2 +-
.../mpp/operator/process/DeviceMergeOperator.java | 2 +-
.../db/mpp/operator/process/FillOperator.java | 2 +-
.../mpp/operator/process/FilterNullOperator.java | 2 +-
.../mpp/operator/process/GroupByLevelOperator.java | 2 +-
.../db/mpp/operator/process/LimitOperator.java | 8 +-
.../db/mpp/operator/process/OffsetOperator.java | 2 +-
.../db/mpp/operator/process/SortOperator.java | 2 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 41 +-
.../db/mpp/operator/sink/FragmentSinkOperator.java | 2 +-
.../iotdb/db/mpp/operator/sink/SinkOperator.java | 2 +-
.../mpp/operator/source/AlignedSeriesScanUtil.java | 88 ++
.../source/SeriesAggregateScanOperator.java | 2 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 4 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 60 +-
.../db/mpp/schedule/FragmentInstanceManager.java | 82 +-
.../db/mpp/schedule/IFragmentInstanceManager.java | 12 +-
.../iotdb/db/mpp/schedule/ITaskScheduler.java | 2 +-
.../mpp/schedule/queue/IndexedBlockingQueue.java | 13 +
.../db/mpp/schedule/queue/L1PriorityQueue.java | 5 +
.../db/mpp/schedule/queue/L2PriorityQueue.java | 6 +
.../db/mpp/schedule/task/FragmentInstanceTask.java | 6 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 55 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 112 ++-
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 12 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 11 +-
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 119 +++
...hemaFetcher.java => FakeSchemaFetcherImpl.java} | 19 +-
.../db/mpp/sql/analyze/IPartitionFetcher.java | 12 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 11 +-
.../sql/analyze/StandalonePartitionFetcher.java | 12 +-
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 11 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 19 +-
.../db/mpp/sql/parser/StatementGenerator.java | 52 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 34 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 26 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 222 ++++-
.../db/mpp/sql/planner/plan/FragmentInstance.java | 17 +-
.../db/mpp/sql/planner/plan/PlanFragment.java | 10 +-
.../plan/SimpleFragmentParallelPlanner.java | 9 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 30 +-
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 7 +
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 52 +-
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 4 +
.../plan/node/metedata/read/ShowDevicesNode.java | 9 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 9 +-
.../write/CreateAlignedTimeSeriesNode.java | 9 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 9 +-
.../planner/plan/node/process/AggregateNode.java | 11 +-
.../planner/plan/node/process/DeviceMergeNode.java | 37 +-
.../planner/plan/node/process/ExchangeNode.java | 30 +-
.../sql/planner/plan/node/process/FillNode.java | 35 +-
.../sql/planner/plan/node/process/FilterNode.java | 40 +-
.../planner/plan/node/process/FilterNullNode.java | 43 +-
.../plan/node/process/GroupByLevelNode.java | 32 +-
.../sql/planner/plan/node/process/LimitNode.java | 21 +-
.../sql/planner/plan/node/process/OffsetNode.java | 31 +-
.../sql/planner/plan/node/process/SortNode.java | 35 +-
.../planner/plan/node/process/TimeJoinNode.java | 33 +-
.../sql/planner/plan/node/sink/CsvSinkNode.java | 67 --
.../planner/plan/node/sink/FragmentSinkNode.java | 21 +-
.../sql/planner/plan/node/sink/ThriftSinkNode.java | 69 --
.../planner/plan/node/source/CsvSourceNode.java | 80 --
.../plan/node/source/SeriesAggregateScanNode.java | 42 +-
.../planner/plan/node/source/SeriesScanNode.java | 71 +-
.../sql/planner/plan/node/source/SourceNode.java | 28 +-
.../plan/node/write/InsertMultiTabletNode.java | 9 +-
.../sql/planner/plan/node/write/InsertNode.java | 57 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 57 +-
.../planner/plan/node/write/InsertRowsNode.java | 9 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +-
.../planner/plan/node/write/InsertTabletNode.java | 221 ++++-
.../sql/rewriter/ColumnPaginationController.java | 101 +++
.../db/mpp/sql/rewriter/ConcatPathRewriter.java | 308 ++-----
.../db/mpp/sql/rewriter/IStatementRewriter.java | 33 -
.../db/mpp/sql/rewriter/WildcardsRemover.java | 339 ++++++--
.../iotdb/db/mpp/sql/statement/StatementNode.java | 2 -
.../sql/{tree => statement}/StatementVisitor.java | 14 +-
.../statement/component}/FillPolicy.java | 2 +-
.../statement/component/FilterNullComponent.java | 8 +-
.../statement/component}/FilterNullPolicy.java | 2 +-
.../statement/component/GroupByLevelComponent.java | 6 +
.../component/GroupByLevelController.java | 10 +-
.../mpp/sql/statement/component/ResultColumn.java | 11 +-
.../sql/statement/component/SelectComponent.java | 21 +-
.../sql/statement/crud/InsertBaseStatement.java | 59 ++
.../mpp/sql/statement/crud/InsertRowStatement.java | 203 +++++
.../db/mpp/sql/statement/crud/InsertStatement.java | 2 +-
.../sql/statement/crud/InsertTabletStatement.java | 96 +++
.../db/mpp/sql/statement/crud/QueryStatement.java | 2 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 2 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 2 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../apache/iotdb/db/mpp/sql/tree/Expression.java | 21 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 91 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 4 +-
.../iotdb/db/qp/logical/crud/SelectComponent.java | 4 +-
.../db/qp/logical/crud/UDAFQueryOperator.java | 4 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 3 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 3 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 4 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 4 +-
.../iotdb/db/query/control/SessionManager.java | 15 +
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 2 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 16 +-
.../iotdb/db/query/expression/Expression.java | 12 +-
.../query/expression/binary/BinaryExpression.java | 25 +-
.../db/query/expression/unary/ConstantOperand.java | 15 +
.../query/expression/unary/FunctionExpression.java | 56 +-
.../query/expression/unary/LogicNotExpression.java | 21 +-
.../query/expression/unary/NegationExpression.java | 21 +-
.../query/expression/unary/TimeSeriesOperand.java | 23 +-
.../query/reader/chunk/MemAlignedPageReader.java | 39 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 119 ++-
.../iotdb/db/service/InternalServiceImpl.java | 13 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 8 +-
.../db/service/thrift/impl/TSServiceImpl.java | 77 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 2 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 6 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 15 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 4 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 46 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 4 +-
.../engine/compaction/AbstractCompactionTest.java | 6 +-
.../engine/compaction/CompactionSchedulerTest.java | 60 +-
.../compaction/TestUtilsForAlignedSeries.java | 6 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 4 +-
.../db/engine/compaction/cross/MergeTest.java | 4 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 4 +-
.../inner/InnerCompactionMoreDataTest.java | 4 +-
.../inner/InnerCompactionSchedulerTest.java | 31 +
.../compaction/inner/InnerCompactionTest.java | 4 +-
.../compaction/inner/InnerSeqCompactionTest.java | 4 +-
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 4 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 4 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 4 +-
.../recover/SizeTieredCompactionRecoverTest.java | 4 +-
.../engine/modification/DeletionFileNodeTest.java | 4 +-
.../db/engine/modification/DeletionQueryTest.java | 4 +-
.../storagegroup/FileNodeManagerBenchmark.java | 8 +-
.../storagegroup/StorageGroupProcessorTest.java | 58 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 21 +-
...neAdvancedTest.java => SchemaAdvancedTest.java} | 72 +-
...maEngineBasicTest.java => SchemaBasicTest.java} | 950 +++++++++++----------
...gineImproveTest.java => SchemaImproveTest.java} | 36 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 116 +--
.../db/metadata/idtable/IDTableFlushTimeTest.java | 6 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 70 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 16 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 15 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 48 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 20 +-
.../iotdb/db/mpp/common/PathPatternTreeTest.java | 131 +++
.../apache/iotdb/db/mpp/common/SchemaTreeTest.java | 214 +++++
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 170 ++++
.../db/mpp/operator/SeriesScanOperatorTest.java | 125 +++
.../db/mpp/operator/TimeJoinOperatorTest.java | 156 ++++
.../db/mpp/schedule/DefaultTaskSchedulerTest.java | 411 +++++++++
.../mpp/schedule/FragmentInstanceManagerTest.java | 134 +++
.../FragmentInstanceTimeoutSentinelTest.java | 283 ++++++
.../db/mpp/schedule/queue/L1PriorityQueueTest.java | 26 +
.../db/mpp/schedule/queue/L2PriorityQueueTest.java | 28 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 93 +-
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 219 +++++
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 79 +-
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 63 ++
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 32 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 14 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 12 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 8 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 12 +-
.../iotdb/db/qp/physical/SerializationTest.java | 10 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 14 +-
.../reader/series/SeriesAggregateReaderTest.java | 3 +-
.../reader/series/SeriesReaderByTimestampTest.java | 3 +-
.../db/query/reader/series/SeriesReaderTest.java | 3 +-
.../query/reader/series/SeriesReaderTestUtil.java | 29 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 4 +-
.../db/sync/receiver/load/FileLoaderTest.java | 24 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 12 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 2 +-
.../sender/recover/SyncSenderLogAnalyzerTest.java | 2 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 26 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 6 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 10 +-
.../db/writelog/recover/DeviceStringTest.java | 12 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 4 +-
.../recover/RecoverResourceFromReaderTest.java | 8 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 8 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 8 +-
.../org/apache/iotdb/rpc/RedirectException.java | 6 +-
.../src/main/thrift/confignode.thrift | 63 +-
thrift/src/main/thrift/mpp.thrift | 16 +-
tsfile/pom.xml | 8 +
.../apache/iotdb/tsfile/read/common/Column.java | 21 -
.../iotdb/tsfile/read/common/TimeColumn.java | 21 -
.../apache/iotdb/tsfile/read/common/TsBlock.java | 175 ----
.../iotdb/tsfile/read/common/block/TsBlock.java | 317 +++++++
.../tsfile/read/common/block/TsBlockBuilder.java | 295 +++++++
.../read/common/block/TsBlockBuilderStatus.java | 75 ++
.../read/common/{ => block}/TsBlockMetadata.java | 2 +-
.../read/common/block/column/BinaryColumn.java | 110 +++
.../common/block/column/BinaryColumnBuilder.java | 148 ++++
.../read/common/block/column/BooleanColumn.java | 109 +++
.../common/block/column/BooleanColumnBuilder.java | 150 ++++
.../tsfile/read/common/block/column/Column.java | 87 ++
.../read/common/block/column/ColumnBuilder.java | 81 ++
.../common/block/column/ColumnBuilderStatus.java | 91 ++
.../read/common/block/column/ColumnUtil.java | 97 +++
.../read/common/block/column/DoubleColumn.java | 109 +++
.../common/block/column/DoubleColumnBuilder.java | 150 ++++
.../read/common/block/column/FloatColumn.java | 108 +++
.../common/block/column/FloatColumnBuilder.java | 150 ++++
.../tsfile/read/common/block/column/IntColumn.java | 108 +++
.../read/common/block/column/IntColumnBuilder.java | 150 ++++
.../read/common/block/column/LongColumn.java | 108 +++
.../common/block/column/LongColumnBuilder.java | 150 ++++
.../block/column/RunLengthEncodedColumn.java | 133 +++
.../read/common/block/column/TimeColumn.java | 95 +++
.../common/block/column/TimeColumnBuilder.java | 126 +++
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 43 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 87 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 4 +-
.../iotdb/tsfile/common/block/TsBlockTest.java | 317 +++++++
437 files changed, 15281 insertions(+), 4616 deletions(-)
rename .github/workflows/{client.yml => client-cpp.yml} (87%)
create mode 100644 .github/workflows/client-python.yml
delete mode 100644 client-py/SessionAlignedTimeseriesTest.py
delete mode 100644 client-py/SessionTest.py
create mode 100644 client-py/tests/test_aligned_timeseries.py
create mode 100644 client-py/tests/test_session.py
rename cluster/src/main/java/org/apache/iotdb/cluster/metadata/{CSchemaEngine.java => CSchemaProcessor.java} (99%)
rename cluster/src/test/java/org/apache/iotdb/cluster/partition/{SchemaEngineWhiteBox.java => SchemaProcessorWhiteBox.java} (67%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{StorageGroupSchemaDataSet.java => DataPartitionDataSet.java} (70%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/SchemaPartitionDataSet.java
copy confignode/src/main/java/org/apache/iotdb/confignode/manager/{ConfigManager.java => ConsensusManager.java} (86%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/Manager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/PartitionManager.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/RegionManager.java
rename confignode/src/main/java/org/apache/iotdb/confignode/partition/{DataPartitionInfo.java => DataRegionInfo.java} (54%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/partition/PartitionTable.java
rename confignode/src/main/java/org/apache/iotdb/confignode/partition/{SchemaPartitionInfo.java => SchemaRegionInfo.java} (58%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/DataNodeInfoPersistence.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/PartitionInfoPersistence.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/RegionInfoPersistence.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/DataPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/SchemaPartitionPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/util/SerializeDeserializeUtil.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/consensus/RatisConsensusDemo.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/utils/SerializeDeserializeUtilTest.java
create mode 100644 consensus/README.md
rename {confignode/src/main/java/org/apache/iotdb/confignode/consensus => consensus/src/main/java/org/apache/iotdb/consensus/common}/ConsensusType.java (97%)
create mode 100644 example/rest-client-c-example/README.md
create mode 100644 example/rest-client-c-example/base64.c
copy server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/PathPatternNode.java => example/rest-client-c-example/base64.h (77%)
create mode 100644 example/rest-client-c-example/main.c
rename {consensus/src/main/java/org/apache/iotdb/consensus/common => node-commons/src/main/java/org/apache/iotdb/commons/cluster}/Endpoint.java (74%)
rename {consensus/src/main/java/org/apache/iotdb/consensus/common => node-commons/src/main/java/org/apache/iotdb/commons/consensus}/ConsensusGroupId.java (70%)
rename {consensus/src/main/java/org/apache/iotdb/consensus/common => node-commons/src/main/java/org/apache/iotdb/commons/consensus}/GroupType.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/partition/DataNodeInfo.java => node-commons/src/main/java/org/apache/iotdb/commons/partition/DataNodeLocation.java (69%)
rename node-commons/src/main/java/org/apache/iotdb/commons/partition/{DataPartitionInfo.java => DataPartition.java} (54%)
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataRegionId.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/DataRegionReplicaSet.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSet.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartition.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaPartitionInfo.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaRegionId.java
delete mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/partition/SchemaRegionReplicaSet.java
rename node-commons/src/main/java/org/apache/iotdb/commons/partition/{DeviceGroupId.java => SeriesPartitionSlot.java} (85%)
rename node-commons/src/main/java/org/apache/iotdb/commons/partition/{TimePartitionId.java => TimePartitionSlot.java} (96%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{SchemaEngine.java => LocalSchemaProcessor.java} (96%)
rename server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/{SchemaRegionManager.java => SchemaEngine.java} (73%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/SchemaTreeVisitor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/operator/source/AlignedSeriesScanUtil.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/FakePartitionFetcherImpl.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/{ClusterSchemaFetcher.java => FakeSchemaFetcherImpl.java} (75%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/CsvSinkNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/sink/ThriftSinkNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/CsvSourceNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/ColumnPaginationController.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/IStatementRewriter.java
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/{tree => statement}/StatementVisitor.java (86%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{common => sql/statement/component}/FillPolicy.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{common => sql/statement/component}/FilterNullPolicy.java (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/tree/Expression.java
rename server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineAdvancedTest.java => SchemaAdvancedTest.java} (76%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineBasicTest.java => SchemaBasicTest.java} (68%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineImproveTest.java => SchemaImproveTest.java} (83%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/PathPatternTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/SchemaTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/SeriesScanOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/DefaultTaskSchedulerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/schedule/FragmentInstanceTimeoutSentinelTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryPlannerTest.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/Column.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/TimeColumn.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/TsBlock.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlock.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/TsBlockBuilderStatus.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/{ => block}/TsBlockMetadata.java (97%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BinaryColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BooleanColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/BooleanColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/Column.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnBuilderStatus.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/ColumnUtil.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/DoubleColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/FloatColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/FloatColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/IntColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/LongColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/LongColumnBuilder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthEncodedColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/TimeColumn.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/TimeColumnBuilder.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/TsBlockTest.java