This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/refactorFilter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 80312a70a81 revert modify about IExpression
add c3c5cbc011e [IOTDB-6254] Fix limit push down bug in aligned sensor
add 278ee6570ea Fix AutoCreateSchema using template without WRITE_SCHEMA
add 7f425fc586d Fix flasky ITs (#11574)
add 89708420e16 Use template to reduce the repeated creation and
serialization in align by device query
add 0f18f38b11d Improve Statistics deserialization
add f94b365350d Fix Some Code Smells of DataNode Module (#11606)
add d0c88113033 fix iotdb-common.sh to check port (#11524)
add cb253412e25 Asynchronously make memtable checkpoints for wal (#11556)
add a216d372d1c Fix Some Code Smells of Examples Module (#11607)
add 022bd455f89 Fix fetch nested device with template will miss some
devices (#11597)
add 70623a50d34 Merge remote-tracking branch 'origin/master' into
lmh/refactorFilter
add 4f0eee3438b merge master
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 4 +-
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 4 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 4 +-
.../iotdb/flink/FlinkTsFileStreamSource.java | 4 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 4 +-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 8 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 8 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 6 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 4 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 4 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 6 +-
.../main/java/org/apache/iotdb/kafka/Consumer.java | 8 +-
.../org/apache/iotdb/kafka/ConsumerThread.java | 4 +-
.../main/java/org/apache/iotdb/kafka/Producer.java | 4 +-
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 4 -
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 4 +-
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 4 +-
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 6 +-
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 4 +-
.../main/java/org/apache/iotdb/HttpExample.java | 20 +-
.../main/java/org/apache/iotdb/HttpsExample.java | 20 +-
.../src/main/java/org/apache/iotdb/SSLClient.java | 4 +-
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 6 +-
.../apache/iotdb/rocketmq/RocketMQProducer.java | 5 +-
.../org/apache/iotdb/schema/PathCheckExample.java | 26 +-
.../org/apache/iotdb/DataMigrationExample.java | 14 +-
.../iotdb/HybridTimeseriesSessionExample.java | 7 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 12 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 6 +-
.../iotdb/SyntaxConventionRelatedExample.java | 7 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 8 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 6 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 4 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 4 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 4 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +-
.../iotdb/itbase/runtime/ClusterTestStatement.java | 10 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 7 +
.../IoTDBOrderByLimitOffsetAlignByDeviceIT.java | 7 +
...java => IoTDBAlignedOffsetLimitPushDownIT.java} | 98 +++++---
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 22 ++
.../db/it/auth/IoTDBTemplatePermissionIT.java | 5 -
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 6 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 80 +++---
.../IoTConsensusDataRegionStateMachine.java | 7 +-
.../request/PipeTransferTabletBatchReq.java | 2 +-
.../protocol/opcua/OpcUaKeyStoreLoader.java | 5 +-
.../protocol/opcua/OpcUaServerBuilder.java | 4 +-
.../common/schematree/ClusterSchemaTree.java | 27 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 3 -
.../db/queryengine/plan/analyze/TemplatedInfo.java | 275 +++++++++++++++++++++
.../db/queryengine/plan/analyze/TypeProvider.java | 99 +++-----
.../analyze/schema/AutoCreateSchemaExecutor.java | 86 +++----
.../plan/planner/OperatorTreeGenerator.java | 13 +-
.../plan/planner/SubPlanTypeExtractor.java | 9 +-
.../plan/planner/TemplatedLogicalPlan.java | 34 ++-
.../plan/planner/TemplatedLogicalPlanBuilder.java | 3 +
.../plan/planner/plan/PlanFragment.java | 36 ++-
.../plan/planner/plan/node/PlanNode.java | 18 +-
.../plan/planner/plan/node/PlanNodeType.java | 17 ++
.../plan/node/process/SingleDeviceViewNode.java | 28 +++
.../plan/node/source/AlignedSeriesScanNode.java | 35 +++
.../InternalBatchActivateTemplateStatement.java | 33 ++-
.../template/AlterSchemaTemplateStatement.java | 23 +-
.../iotdb/db/storageengine/StorageEngine.java | 76 +++---
.../execute/recover/CompactionRecoverTask.java | 27 +-
.../compaction/schedule/CompactionWorker.java | 13 +-
.../dataregion/wal/buffer/WALBuffer.java | 52 +++-
.../dataregion/wal/buffer/WALEntry.java | 3 +
.../dataregion/wal/buffer/WALEntryType.java | 2 +
.../dataregion/wal/buffer/WALInfoEntry.java | 2 +
.../dataregion/wal/buffer/WALSignalEntry.java | 13 +-
.../dataregion/wal/checkpoint/Checkpoint.java | 10 +-
.../wal/checkpoint/CheckpointManager.java | 25 +-
.../dataregion/wal/checkpoint/MemTableInfo.java | 10 +-
.../storageengine/dataregion/wal/node/WALNode.java | 20 +-
.../rescon/disk/strategy/DirectoryStrategy.java | 4 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 2 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 8 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 14 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 4 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 8 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 30 +++
.../compaction/CompactionTaskManagerTest.java | 10 +-
.../wal/checkpoint/CheckpointManagerTest.java | 7 +-
.../dataregion/wal/node/WALEntryHandlerTest.java | 2 +
.../dataregion/wal/node/WALNodeTest.java | 4 +
.../wal/recover/WALRecoverManagerTest.java | 40 +--
.../wal/utils/WALInsertNodeCacheTest.java | 9 +-
.../metricsets/disk/LinuxDiskMetricsManager.java | 12 +-
.../metricsets/net/LinuxNetMetricManager.java | 12 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 15 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../file/metadata/statistics/BinaryStatistics.java | 6 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 87 +++++--
.../tsfile/read/reader/page/ValuePageReader.java | 128 +++++++---
97 files changed, 1298 insertions(+), 606 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBCountMultiTimesWithDeletionIT.java
=> IoTDBAlignedOffsetLimitPushDownIT.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/TemplatedInfo.java
