This is an automated email from the ASF dual-hosted git repository.
jianyun pushed a change to branch rocksdb/dev
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from ad3b863 reolve merge conflicts
add 681398c [rocksdb] clean code.
add 1968b0f [RocksDB] import existed UT and support removing empty parent
when delete timeseries
add 657c4f0 spotless apply
add 65bdae4 Merge branch 'jianyun/rocksdb-dev' into 'feature/rocksdb'
add 02a3fc2 [IOTDB-2666] Add InternalService to mpp.thrift (#5339)
add 8f9d829 [IOTDB-2762][metrics] Fix inconsistent name between
dropwizard implementation and micrometer implementation (#5301)
add 44fb2d1 [IOTDB-2774] classloader isolation for MQTT plugin (#5305)
add d53f4fa [IOTDB-2561]Compaction code refactoring for restart recovery
and exception handling (#5316)
add c6a968c change ratis log level (#5346)
add f36f29c Ratis Consensus Impl Bug Fix (#5348)
add ce4d28f [IOTDB-2768] Simply Implement SeriesScanOperator and
TimeJoinOperator (#5342)
add 44a1912 open ratis log (#5341)
add 6349cc5 Close MQTTMessageLogger log output in test (#5350)
add 4f4b360 [IOTDB-2780] Config node ratis consensus protocol
implementation (#5347)
add c6e47b9 [IOTDB-2671][metrics] Improve the implementation of
iotdbReporter (#5338)
add 1705a8a [IOTDB-2679] Support logical operators in select clauses
(#5273)
add bbfa720 [IOTDB-2803] adapt metadata write operation to plannode
(#5344)
add b103385 Add SchemaRegion Interfaces to SchemaEngine (#5349)
add 5404730 Rename SchemaEngine to LocalSchemaProcessor and Rename
SchemaRegionManager to SchemaEngine (#5359)
add 0f21cef Fix typos in mpp.thrift (#5360)
add 27f2b96 [IOTDB-2713] Generate Analysis for query statement (#5343)
add 4a70fba [IOTDB-2658] Generate logical plan for query statement (#5356)
add bcd53d7 [IOTDB-2810] Design and implementation of TsBlock and its
builder (#5362)
add 0acb906 Demo for integration of ConfigNode and ratis-consensus (#5361)
add b017eae [IOTDB-2784] Add unit tests for FragmentInstanceTask
scheduling (#5337)
add 4050490 Connect the Query Plan stage from SQL to DistributionPlan
with UT and mock interfaces (#5364)
add 9c5fdd5 [IOTDB-2768] Add UT for SeriesScanOperator, TimeJoinOperator
and LimitOperator (#5365)
add 0f20ca5 Merge branch 'master' into lsj/update_interface
add e0c79b2 [rocksdb] replace SchemaEngine by schemaRegion.
add e451232 [rocksdb] Modify the schemaRegion initialization process.
add 0cd88b6 [rocksdb] UPDATE
add 64d4d08 [rocksdb] remove unused test
add 8cfb2ec [rocksdb] resolve compilation failures(unconfirmed)
add a9dbdc9 [rocksdb] remove GetBelongedToSpecifiedType.java
add 5b5fec3 [rocksdb] deactivate schemaRegion
add efd6ee1 [rocksdb] make ut passed
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 47 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 3 +-
.../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} | 30 +-
.../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 | 5 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../log/applier/AsyncDataLogApplierTest.java | 8 +-
.../cluster/log/applier/DataLogApplierTest.java | 13 +-
.../cluster/log/applier/MetaLogApplierTest.java | 6 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 6 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 2 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 12 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 4 +-
.../log/snapshot/PartitionedSnapshotTest.java | 5 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 3 +-
...eWhiteBox.java => SchemaProcessorWhiteBox.java} | 20 +-
.../cluster/partition/SlotPartitionTableTest.java | 28 +-
.../cluster/query/ClusterPlanExecutorTest.java | 2 +-
.../clusterinfo/ClusterInfoServiceImplTest.java | 4 +-
.../iotdb/cluster/server/member/BaseMember.java | 10 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 22 +-
.../resources/{logback.xml => logback-test.xml} | 2 +-
confignode/pom.xml | 5 +
.../resources/conf/iotdb-confignode.properties | 44 +-
confignode/src/assembly/resources/conf/logback.xml | 4 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 38 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../confignode/conf/ConfigNodeDescriptor.java | 42 +-
.../statemachine/PartitionRegionStateMachine.java | 15 +-
.../iotdb/confignode/manager/ConfigManager.java | 109 +-
.../iotdb/confignode/partition/PartitionTable.java | 11 +-
.../iotdb/confignode/physical/PhysicalPlan.java | 9 +
.../iotdb/confignode/service/ConfigNode.java | 22 +-
.../confignode/service/ConfigNodeCommandLine.java | 6 +-
.../confignode/service/executor/PlanExecutor.java | 4 +-
.../service/thrift/server/ConfigNodeRPCServer.java | 21 +-
.../server/ConfigNodeRPCServerProcessor.java | 7 +-
.../thrift/server/ConfigNodeRPCServiceHandler.java | 2 +-
.../confignode/consensus/RatisConsensusDemo.java | 128 ++
.../manager/ConfigManagerManualTest.java | 132 ++
...java => DeviceGroupHashExecutorManualTest.java} | 8 +-
.../server/ConfigNodeRPCServerProcessorTest.java | 5 +-
.../iotdb/consensus/common/ConsensusType.java | 49 +-
.../iotdb/consensus/ratis/RequestMessage.java | 29 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 18 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 44 +-
consensus/src/main/resources/logback-test.xml | 2 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 2 +-
.../tests/tools/importCsv/ExportCsvTestIT.java | 31 +-
docs/UserGuide/API/Programming-MQTT.md | 2 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +-
docs/UserGuide/Query-Data/Select-Expression.md | 85 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 2 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 14 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 80 +-
example/mqtt-customize/README.md | 4 +-
...apache.iotdb.db.protocol.mqtt.PayloadFormatter} | 0
.../iotdb/db/integration/IoTDBArithmeticIT.java | 18 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 14 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 35 -
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 12 +-
.../IoTDBSelectCompareExpressionIT.java | 482 +++++++
.../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 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 4 +-
.../resources/{logback.xml => logback-test.xml} | 2 +-
metrics/dropwizard-metrics/pom.xml | 1 -
.../iotdb/metrics/dropwizard/MetricName.java | 60 +-
.../reporter/DropwizardIoTDBReporter.java | 5 +-
.../reporter/DropwizardMetricsExporter.java | 169 +--
.../metrics/dropwizard/reporter/IoTDBReporter.java | 202 +--
.../org.apache.iotdb.metrics.reporter.Reporter | 3 +-
metrics/interface/pom.xml | 5 +
.../main/assembly/resources/conf/iotdb-metric.yml | 14 +-
.../org/apache/iotdb/metrics/MetricService.java | 22 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 133 +-
.../iotdb/metrics/reporter/CompositeReporter.java | 14 +-
.../apache/iotdb/metrics/utils/MetricsUtils.java | 33 +-
.../interface/src/test/resources/iotdb-metric.yml | 14 +-
.../micrometer/reporter}/IoTDBMeterRegistry.java | 112 +-
.../micrometer/reporter}/IoTDBRegistryConfig.java | 7 +-
.../{IoTDBJmxConfig.java => JmxConfig.java} | 6 +-
.../reporter/MicrometerIoTDBReporter.java | 4 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 2 +-
.../org.apache.iotdb.metrics.reporter.Reporter | 3 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../commons/partition/DataRegionReplicaSet.java | 8 +
.../iotdb/commons/partition/SchemaRegionId.java | 23 +
.../iotdb/commons/service/RegisterManager.java | 2 +-
pom.xml | 10 +
.../assembly/resources/tools/rocksdb-transfer.bat | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 57 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 21 +-
.../engine/compaction/CompactionTaskManager.java | 14 +-
.../db/engine/compaction/CompactionUtils.java | 4 +-
.../cross/AbstractCrossSpaceCompactionTask.java | 13 +-
.../compaction/cross/CrossCompactionStrategy.java | 21 -
.../selector/RewriteCompactionFileSelector.java | 8 +-
.../task/RewriteCrossCompactionRecoverTask.java | 467 -------
.../task/RewriteCrossSpaceCompactionTask.java | 13 +-
.../inner/AbstractInnerSpaceCompactionTask.java | 6 +-
.../compaction/inner/InnerCompactionStrategy.java | 25 -
.../InnerSpaceCompactionExceptionHandler.java | 277 ----
.../SizeTieredCompactionRecoverTask.java | 303 -----
.../inner/sizetiered/SizeTieredCompactionTask.java | 37 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 13 +-
.../compaction/task/AbstractCompactionTask.java | 15 +-
.../CompactionExceptionHandler.java} | 123 +-
...overTask.java => CompactionRecoverManager.java} | 92 +-
.../compaction/task/CompactionRecoverTask.java | 519 +++++++-
.../compaction/utils/log/CompactionLogger.java | 7 +-
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 2 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 106 +-
.../service/TriggerRegistrationService.java | 2 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 6 +-
.../apache/iotdb/db/metadata/ISchemaEngine.java | 368 ------
.../iotdb/db/metadata/LocalConfigManager.java | 784 +++++++++++
.../db/metadata/LocalSchemaPartitionTable.java | 121 ++
...SchemaEngine.java => LocalSchemaProcessor.java} | 686 +++-------
.../apache/iotdb/db/metadata/MetadataConstant.java | 1 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 10 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 6 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 -
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 9 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 17 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 18 -
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 78 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 75 +-
.../traverser/collector/MNodeAboveSGCollector.java | 9 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../counter/MNodeAboveSGLevelCounter.java | 9 +-
.../rocksdb/GetBelongedToSpecifiedType.java | 117 --
.../db/metadata/schemaregion/ISchemaRegion.java | 205 +++
.../db/metadata/schemaregion/SchemaEngine.java | 103 ++
.../metadata/{ => schemaregion}/SchemaRegion.java | 191 +--
.../{ => schemaregion}/rocksdb/CheckKeyResult.java | 6 +-
.../rocksdb/RSchemaConstants.java | 2 +-
.../{ => schemaregion}/rocksdb/RSchemaLogger.java | 2 +-
.../rocksdb/RSchemaReadWriteHandler.java | 363 +++--
.../rocksdb/RSchemaRegion.java} | 1385 ++++++-------------
.../{ => schemaregion}/rocksdb/RSchemaUtils.java | 82 +-
.../rocksdb/SchemaDataTransfer.java | 129 +-
.../rocksdb/mnode/REntityMNode.java | 6 +-
.../rocksdb/mnode/RInternalMNode.java | 8 +-
.../{ => schemaregion}/rocksdb/mnode/RMNode.java | 11 +-
.../rocksdb/mnode/RMNodeType.java | 10 +-
.../rocksdb/mnode/RMNodeValueType.java | 4 +-
.../rocksdb/mnode/RMeasurementMNode.java | 8 +-
.../rocksdb/mnode/RStorageGroupMNode.java | 17 +-
.../IStorageGroupSchemaManager.java | 56 +-
.../storagegroup/StorageGroupLogReader.java} | 35 +-
.../storagegroup/StorageGroupLogWriter.java | 56 +
.../StorageGroupSchemaManager.java | 189 +--
.../iotdb/db/metadata/template/Template.java | 33 +-
.../db/metadata/template/TemplateManager.java | 56 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 66 +-
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 4 +-
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 12 +-
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 2 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 2 +-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 2 +-
.../iotdb/db/mpp/common/MPPQueryContext.java | 6 +-
.../org/apache/iotdb/db/mpp/common/TsBlock.java | 73 -
.../db/mpp/common/schematree/PathPatternNode.java | 68 +-
.../db/mpp/common/schematree/PathPatternTree.java | 104 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 56 +-
.../apache/iotdb/db/mpp/execution/Coordinator.java | 2 +-
.../db/mpp/execution/FragmentInstanceContext.java | 11 +-
.../iotdb/db/mpp/execution/QueryExecution.java | 18 +-
.../execution/scheduler/StandaloneScheduler.java | 4 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 8 +-
.../iotdb/db/mpp/operator/OperatorContext.java | 13 +-
.../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 | 16 +-
.../db/mpp/operator/process/OffsetOperator.java | 2 +-
.../db/mpp/operator/process/SortOperator.java | 2 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 144 +-
.../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 | 110 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 1388 ++++++++++++++++++++
.../db/mpp/schedule/FragmentInstanceManager.java | 70 +-
.../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 | 2 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 28 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 93 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 11 -
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 107 ++
.../analyze/FakeSchemaFetcherImpl.java} | 21 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 8 -
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 11 -
.../iotdb/db/mpp/sql/constant/FilterConstant.java | 3 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 108 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 9 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 37 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 213 ++-
.../db/mpp/sql/planner/plan/FragmentInstance.java | 1 -
.../db/mpp/sql/planner/plan/PlanFragment.java | 2 +-
.../plan/SimpleFragmentParallelPlanner.java | 3 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 30 +-
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 7 +
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 18 +-
.../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 52 +-
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 16 +-
.../plan/node/metedata/read/ShowDevicesNode.java | 9 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 140 ++
.../write/CreateAlignedTimeSeriesNode.java} | 132 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 10 +-
.../planner/plan/node/process/AggregateNode.java | 11 +-
.../planner/plan/node/process/DeviceMergeNode.java | 37 +-
.../planner/plan/node/process/ExchangeNode.java | 22 +-
.../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 | 13 +-
.../sql/planner/plan/node/sink/ThriftSinkNode.java | 69 -
.../planner/plan/node/source/CsvSourceNode.java | 80 --
.../plan/node/source/SeriesAggregateScanNode.java | 30 +-
.../planner/plan/node/source/SeriesScanNode.java | 52 +-
.../sql/planner/plan/node/source/SourceNode.java | 22 +
.../plan/node/write/InsertMultiTabletNode.java | 9 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 9 +-
.../planner/plan/node/write/InsertRowsNode.java | 9 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +-
.../planner/plan/node/write/InsertTabletNode.java | 9 +-
.../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 | 18 +-
.../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 +-
.../db/mpp/sql/statement/crud/InsertStatement.java | 2 +-
.../db/mpp/sql/statement/crud/QueryStatement.java | 2 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 119 ++
.../metadata/CreateAlignedTimeSeriesStatement.java | 17 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../apache/iotdb/db/mpp/sql/tree/Expression.java | 21 -
.../db/protocol/mqtt/PayloadFormatManager.java | 89 +-
.../iotdb/db/qp/constant/FilterConstant.java | 3 +-
.../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 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 38 +
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 3 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 4 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 4 +-
.../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 | 53 +-
.../binary/EqualToExpression.java} | 21 +-
.../binary/GreaterEqualExpression.java} | 23 +-
.../binary/GreaterThanExpression.java} | 22 +-
.../binary/LessEqualExpression.java} | 22 +-
.../binary/LessThanExpression.java} | 22 +-
.../binary/LogicAndExpression.java} | 21 +-
.../binary/LogicOrExpression.java} | 21 +-
.../binary/NonEqualExpression.java} | 22 +-
.../db/query/expression/unary/ConstantOperand.java | 15 +
.../query/expression/unary/FunctionExpression.java | 56 +-
...tionExpression.java => LogicNotExpression.java} | 54 +-
.../query/expression/unary/NegationExpression.java | 21 +-
.../query/expression/unary/TimeSeriesOperand.java | 23 +-
.../query/reader/chunk/MemAlignedPageReader.java | 40 +
.../iotdb/db/query/reader/chunk/MemPageReader.java | 93 ++
.../transformer/ArithmeticAdditionTransformer.java | 2 +-
.../transformer/ArithmeticBinaryTransformer.java | 98 +-
.../transformer/ArithmeticDivisionTransformer.java | 2 +-
.../transformer/ArithmeticModuloTransformer.java | 2 +-
.../ArithmeticMultiplicationTransformer.java | 2 +-
.../ArithmeticSubtractionTransformer.java | 2 +-
...naryTransformer.java => BinaryTransformer.java} | 77 +-
...nsformer.java => CompareBinaryTransformer.java} | 14 +-
...sformer.java => CompareEqualToTransformer.java} | 13 +-
...er.java => CompareGreaterEqualTransformer.java} | 8 +-
...mer.java => CompareGreaterThanTransformer.java} | 8 +-
...ormer.java => CompareLessEqualTransformer.java} | 8 +-
...former.java => CompareLessThanTransformer.java} | 8 +-
...former.java => CompareNonEqualTransformer.java} | 13 +-
...loTransformer.java => LogicAndTransformer.java} | 9 +-
...ransformer.java => LogicBinaryTransformer.java} | 15 +-
.../udf/core/transformer/LogicNotTransformer.java | 66 +
...uloTransformer.java => LogicOrTransformer.java} | 9 +-
.../iotdb/db/service/InternalServiceImpl.java | 41 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 43 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 3 +
.../iotdb/db/service/metrics/MetricsService.java | 4 +-
.../db/service/thrift/impl/TSServiceImpl.java | 20 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 2 +-
.../db/sync/sender/manage/SyncFileManager.java | 2 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 11 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 6 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 4 +-
.../org.apache.iotdb.metrics.reporter.Reporter | 19 -
.../iotdb/db/engine/MetadataManagerHelper.java | 50 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 8 +-
.../engine/compaction/AbstractCompactionTest.java | 10 +-
.../engine/compaction/CompactionSchedulerTest.java | 64 +-
.../compaction/CompactionTaskComparatorTest.java | 38 +-
.../compaction/TestUtilsForAlignedSeries.java | 6 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 31 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 8 +-
.../db/engine/compaction/cross/MergeTest.java | 8 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 74 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 8 +-
.../inner/InnerCompactionMoreDataTest.java | 4 +-
.../compaction/inner/InnerCompactionTest.java | 8 +-
.../compaction/inner/InnerSeqCompactionTest.java | 8 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 64 +-
.../InnerSpaceCompactionUtilsAlignedTest.java | 4 +-
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 6 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 8 +-
.../SizeTieredCompactionRecoverTest.java | 121 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 8 +-
...eCrossSpaceCompactionRecoverCompatibleTest.java | 19 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 59 +-
.../recover/SizeTieredCompactionRecoverTest.java | 125 +-
.../engine/modification/DeletionFileNodeTest.java | 4 +-
.../db/engine/modification/DeletionQueryTest.java | 4 +-
.../storagegroup/FileNodeManagerBenchmark.java | 8 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 16 +-
...neAdvancedTest.java => SchemaAdvancedTest.java} | 72 +-
...maEngineBasicTest.java => SchemaBasicTest.java} | 920 +++++++------
...gineImproveTest.java => SchemaImproveTest.java} | 54 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 120 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 72 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 18 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 8 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 4 +-
.../rocksdb/MRocksDBBenchmark.java | 42 +-
.../rocksdb/MRocksDBUnitTest.java | 206 +--
.../rocksdb/RSchemaReadWriteHandlerTest.java | 8 +-
.../rocksdb/RSchemaRegionAdvancedTest.java} | 148 +--
.../rocksdb/RocksDBBenchmarkEngine.java | 7 +-
.../rocksdb/RocksDBBenchmarkTask.java | 2 +-
.../rocksdb/RocksDBTestUtils.java | 2 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 24 +-
.../iotdb/db/mpp/common/PathPatternTreeTest.java | 131 ++
.../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 +-
.../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 10 +-
.../db/mpp/sql/parser/StatementGeneratorTest.java | 4 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 40 +-
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 219 +++
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 288 +++-
.../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 61 +
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 7 +
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 34 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 4 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 18 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 12 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 10 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 12 +-
.../iotdb/db/qp/physical/SerializationTest.java | 14 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 2 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 14 +-
.../query/dataset/groupby/GroupByDataSetTest.java | 2 +-
.../dataset/groupby/GroupByFillDataSetTest.java | 2 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 2 +-
.../reader/series/SeriesAggregateReaderTest.java | 3 +-
.../reader/series/SeriesReaderByTimestampTest.java | 3 +-
.../db/query/reader/series/SeriesReaderTest.java | 3 +-
.../query/reader/series/SeriesReaderTestUtil.java | 33 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 11 +-
.../db/sync/receiver/load/FileLoaderTest.java | 15 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 15 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 2 +-
.../sender/recover/SyncSenderLogAnalyzerTest.java | 2 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 124 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 8 +-
.../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 +-
.../resources/{logback.xml => logback-test.xml} | 4 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 4 +-
thrift/src/main/thrift/mpp.thrift | 69 +-
tsfile/pom.xml | 8 +
.../iotdb/tsfile/read/common/block/TsBlock.java | 317 +++++
.../tsfile/read/common/block/TsBlockBuilder.java | 295 +++++
.../read/common/block/TsBlockBuilderStatus.java | 75 ++
.../tsfile/read/common/block}/TsBlockMetadata.java | 8 +-
.../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 | 88 ++
.../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 | 3 +
.../tsfile/read/reader/page/AlignedPageReader.java | 44 +
.../iotdb/tsfile/read/reader/page/PageReader.java | 86 ++
.../iotdb/tsfile/common/block/TsBlockTest.java | 317 +++++
468 files changed, 17188 insertions(+), 8064 deletions(-)
rename
cluster/src/main/java/org/apache/iotdb/cluster/metadata/{CSchemaEngine.java =>
CSchemaProcessor.java} (98%)
rename
cluster/src/test/java/org/apache/iotdb/cluster/partition/{SchemaEngineWhiteBox.java
=> SchemaProcessorWhiteBox.java} (67%)
rename cluster/src/test/resources/{logback.xml => logback-test.xml} (98%)
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/manager/ConfigManagerManualTest.java
rename
confignode/src/test/java/org/apache/iotdb/confignode/manager/hash/{DeviceGroupHashExecutorTest.java
=> DeviceGroupHashExecutorManualTest.java} (94%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/CheckKeyResult.java
=> consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java
(53%)
rename
example/mqtt-customize/src/main/resources/META-INF/services/{org.apache.iotdb.db.org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
=> org.apache.iotdb.db.protocol.mqtt.PayloadFormatter} (100%)
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectCompareExpressionIT.java
rename integration/src/test/resources/{logback.xml => logback-test.xml} (99%)
rename {server/src/main/java/org/apache/iotdb/db =>
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb}/metrics/dropwizard/reporter/DropwizardIoTDBReporter.java
(92%)
rename {server/src/main/java/org/apache/iotdb/db =>
metrics/dropwizard-metrics/src/main/java/org/apache/iotdb}/metrics/dropwizard/reporter/IoTDBReporter.java
(53%)
rename server/src/main/java/org/apache/iotdb/db/metrics/metricsUtils.java =>
metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricsUtils.java
(69%)
rename {server/src/main/java/org/apache/iotdb/db/metrics/micrometer/registry
=>
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter}/IoTDBMeterRegistry.java
(61%)
rename {server/src/main/java/org/apache/iotdb/db/metrics/micrometer/registry
=>
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter}/IoTDBRegistryConfig.java
(85%)
rename
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/{IoTDBJmxConfig.java
=> JmxConfig.java} (88%)
rename {server/src/main/java/org/apache/iotdb/db =>
metrics/micrometer-metrics/src/main/java/org/apache/iotdb}/metrics/micrometer/reporter/MicrometerIoTDBReporter.java
(93%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/RewriteCrossCompactionRecoverTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionExceptionHandler.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionRecoverTask.java
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/CrossSpaceCompactionExceptionHandler.java
=> task/CompactionExceptionHandler.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/{CompactionRecoverTask.java
=> CompactionRecoverManager.java} (52%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/ISchemaEngine.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/LocalConfigManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaPartitionTable.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{SchemaEngine.java =>
LocalSchemaProcessor.java} (67%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/rocksdb/GetBelongedToSpecifiedType.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/ISchemaRegion.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngine.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/SchemaRegion.java (91%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/CheckKeyResult.java (85%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RSchemaConstants.java (97%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RSchemaLogger.java (96%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RSchemaReadWriteHandler.java (61%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/{rocksdb/RSchemaEngine.java
=> schemaregion/rocksdb/RSchemaRegion.java} (64%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RSchemaUtils.java (80%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/SchemaDataTransfer.java (82%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/REntityMNode.java (93%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/RInternalMNode.java (96%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/RMNode.java (94%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/RMNodeType.java (64%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/RMNodeValueType.java (91%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/RMeasurementMNode.java (95%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/mnode/RStorageGroupMNode.java (82%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
storagegroup}/IStorageGroupSchemaManager.java (82%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/operator/process/SortOperator.java
=> metadata/storagegroup/StorageGroupLogReader.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupLogWriter.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
storagegroup}/StorageGroupSchemaManager.java (54%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/TsBlock.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/operator/source/SeriesScanUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/FakePartitionFetcherImpl.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/{operator/SeriesScanOperator.java
=> sql/analyze/FakeSchemaFetcherImpl.java} (71%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/sql/{statement/metadata/CreateAlignedTimeSeriesStatement.java
=> planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java} (54%)
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 (80%)
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/metadata/AlterTimeSeriesStatement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/sql/tree/Expression.java
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticDivisionTransformer.java
=> expression/binary/EqualToExpression.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticAdditionTransformer.java
=> expression/binary/GreaterEqualExpression.java} (52%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticDivisionTransformer.java
=> expression/binary/GreaterThanExpression.java} (52%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticDivisionTransformer.java
=> expression/binary/LessEqualExpression.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticDivisionTransformer.java
=> expression/binary/LessThanExpression.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticModuloTransformer.java
=> expression/binary/LogicAndExpression.java} (54%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticModuloTransformer.java
=> expression/binary/LogicOrExpression.java} (54%)
copy
server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticDivisionTransformer.java
=> expression/binary/NonEqualExpression.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/query/expression/unary/{NegationExpression.java
=> LogicNotExpression.java} (80%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticBinaryTransformer.java
=> BinaryTransformer.java} (61%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticMultiplicationTransformer.java
=> CompareBinaryTransformer.java} (75%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticMultiplicationTransformer.java
=> CompareEqualToTransformer.java} (75%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java
=> CompareGreaterEqualTransformer.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticAdditionTransformer.java
=> CompareGreaterThanTransformer.java} (80%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticAdditionTransformer.java
=> CompareLessEqualTransformer.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticAdditionTransformer.java
=> CompareLessThanTransformer.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticMultiplicationTransformer.java
=> CompareNonEqualTransformer.java} (75%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java
=> LogicAndTransformer.java} (76%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticMultiplicationTransformer.java
=> LogicBinaryTransformer.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/LogicNotTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java
=> LogicOrTransformer.java} (76%)
delete mode 100644
server/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.Reporter
copy
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} (77%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/MRocksDBBenchmark.java (88%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/MRocksDBUnitTest.java (56%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RSchemaReadWriteHandlerTest.java (91%)
rename
server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineAdvancedTest.java
=> schemaregion/rocksdb/RSchemaRegionAdvancedTest.java} (50%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RocksDBBenchmarkEngine.java (95%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RocksDBBenchmarkTask.java (98%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{ =>
schemaregion}/rocksdb/RocksDBTestUtils.java (97%)
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/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
rename server/src/test/resources/{logback.xml => logback-test.xml} (93%)
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 {server/src/main/java/org/apache/iotdb/db/mpp/common =>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block}/TsBlockMetadata.java
(85%)
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
