This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch IOTDB-6199
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8979ce6879d resolve conflicts
add 63475a16592 Pipe: Add pipeSinkHandshakeTimeout parameter to
distinguish it from pipeSinkTransferTimeout & Call handshake() method of
temporary connector's to validate createPipeStatement (#11655)
add baae7ce0332 Fix snapshot UT (#11697)
add 4e72d07de9b Featrue add insertRecords and insertTablets to the rest v2
service for data type verification (#11708)
add fb23bd43639 fix(cli): add jna for windows (#11707)
add f61f310c277 fix Precondition failure (#11710)
add f12b5eb5f51 add IT testing to rest service (#11437)
add 795d420db86 Pipe: rename iotdb-thrift-ssl-sink & allow not specifying
connector in kv attrs & support kv attrs that don't have sink. / processor. /
sink. prefixes (#11715)
add 3e4c6a4df91 Pipe Schema: Receiver Agent: Added pipe enriched planNode
to enable pipe request detection to configure "forwarding-pipe-request" (#11672)
add ac326a59e40 Improved stability of Ratis addMemberToGroup and
testThresholdSnapshot UT (#11717)
add 88549541f6b Add a param to switch whether to enable data separation or
not (#11692)
add 8c8c8d58523 [IOTDB-5706] Data inconsistency between IoT protocol
replications (#11727)
add 13c047fe7bc IT: enable REST service when needed to fix IT (#11726)
add 54a3733263f Take snapshot for mods using copy instead of hard link
(#11728)
add 1c886d255b6 change default config value of
inner_compaction_task_selection_mods_file_threshold (#11703)
add fd9cb6ed8b7 Implement Cluster ID (#11702)
add 301033fe015 Show devices with template (#11681)
add 40c32518da0 Pipe Schema: Receiver Agent: config plan node to statement
transformation logic (#11689)
add ef6dc0a8e14 Pipe: enhance the idempotence of start / stop pipe
(#11713)
add 720d4729bd1 SeriesScanUtil support predicate pushdown
add c368568028b Merge remote-tracking branch 'origin/master' into
IOTDB-6199
add e7299096e35 fix NPE
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 26 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 11 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../it/cluster/IoTDBClusterRestartIT.java | 17 +-
.../confignode/it/cluster/IoTDBClusterStartIT.java | 93 +
.../apache/iotdb/db/it/GrafanaApiServiceIT.java | 451 +++++
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 2119 ++++++++++++++++++++
.../iotdb/db/it/auth/IoTDBClusterAuthorityIT.java | 5 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 4 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 75 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 7 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 85 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 108 +-
.../apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java | 22 +-
.../apache/iotdb/pipe/it/IoTDBPipeLifeCycleIT.java | 97 +
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 10 +-
.../api/customizer/parameter/PipeParameters.java | 104 +-
iotdb-client/cli/pom.xml | 17 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../org/apache/iotdb/session/NodesSupplier.java | 23 +-
.../org/apache/iotdb/session/ThriftConnection.java | 6 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 13 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../consensus/request/ConfigPhysicalPlan.java | 8 +
.../consensus/request/ConfigPhysicalPlanType.java | 5 +-
.../write/confignode/UpdateClusterIdPlan.java | 76 +
.../request/write/pipe/PipeEnrichedPlan.java | 79 +
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ClusterManager.java | 67 +
.../iotdb/confignode/manager/ConfigManager.java | 21 +-
.../apache/iotdb/confignode/manager/IManager.java | 10 +
.../iotdb/confignode/manager/ProcedureManager.java | 17 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 10 +-
.../iotdb/confignode/persistence/ClusterInfo.java | 109 +
.../persistence/executor/ConfigPlanExecutor.java | 13 +
.../persistence/pipe/PipePluginInfo.java | 13 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 52 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 18 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 3 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 3 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 3 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 4 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 24 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 24 +-
.../confignode/service/ConfigNodeShutdownHook.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 45 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +
.../confignode/persistence/ClusterInfoTest.java | 67 +
.../consensus/iot/client/DispatchLogHandler.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 3 +
.../iotdb/consensus/ratis/DiskGuardianTest.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 25 +-
.../iotdb/consensus/ratis/RecoverReadTest.java | 4 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 25 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 16 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +-
.../dataregion/DataExecutionVisitor.java | 29 +-
.../schemaregion/SchemaExecutionVisitor.java | 14 +
.../agent/plugin/PipeConnectorConstructor.java | 13 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 7 +
.../env/PipeTaskTemporaryRuntimeEnvironment.java | 14 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 2 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 48 +-
.../sync/IoTDBThriftSyncConnectorClient.java | 12 +-
.../protocol/writeback/WriteBackConnector.java | 4 +-
.../pipe/receiver/PipePlanToStatementVisitor.java | 186 ++
.../pipe/receiver/airgap/IoTDBAirGapReceiver.java | 2 +-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 10 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 37 +-
.../rest/v2/handler/RequestValidationHandler.java | 43 +
.../common/header/ColumnHeaderConstant.java | 16 +-
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/executor/RegionWriteExecutor.java | 276 ++-
.../execution/load/LoadTsFileManager.java | 4 +-
.../queryengine/execution/load/TsFileSplitter.java | 2 +-
.../operator/schema/source/DeviceSchemaSource.java | 15 +
.../AbstractSeriesAggregationScanOperator.java | 33 +-
.../operator/source/AlignedSeriesScanUtil.java | 148 +-
.../operator/source}/FileLoaderUtils.java | 109 +-
.../execution/operator/source/SeriesScanUtil.java | 553 ++---
.../queryengine/plan/analyze/AnalyzeVisitor.java | 44 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 10 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 102 +-
.../config/executor/IConfigTaskExecutor.java | 10 +
.../config/metadata/ShowClusterIdTask.java | 65 +
.../db/queryengine/plan/parser/ASTVisitor.java | 20 +-
.../plan/planner/LogicalPlanVisitor.java | 60 +-
.../plan/planner/OperatorTreeGenerator.java | 1 -
.../plan/planner/plan/node/PlanNode.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 18 +-
.../plan/planner/plan/node/PlanVisitor.java | 23 +-
.../planner/plan/node/load/LoadTsFileNode.java | 7 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 2 +-
.../metedata/write/view/AlterLogicalViewNode.java | 43 +-
.../node/pipe/PipeEnrichedConfigSchemaNode.java | 161 ++
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 169 ++
.../{write => pipe}/PipeEnrichedInsertNode.java | 19 +-
.../node/pipe/PipeEnrichedWriteSchemaNode.java | 192 ++
.../plan/planner/plan/node/write/InsertNode.java | 10 -
.../planner/plan/parameter/SeriesScanOptions.java | 3 -
.../queryengine/plan/statement/StatementType.java | 3 +-
.../plan/statement/StatementVisitor.java | 18 +-
.../crud/PipeEnrichedInsertBaseStatement.java | 220 --
.../crud/PipeEnrichedLoadTsFileStatement.java | 137 --
.../statement/metadata/ShowClusterIdStatement.java | 18 +-
.../metadata/view/CreateLogicalViewStatement.java | 10 +-
.../plan/statement/pipe/PipeEnrichedStatement.java | 72 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 3 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 3 +-
.../read/resp/info/IDeviceSchemaInfo.java | 2 +
.../read/resp/info/impl/ShowDevicesResult.java | 11 +
.../utils/filter/DeviceFilterVisitor.java | 26 +
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 3 +-
.../db/storageengine/dataregion/DataRegion.java | 193 +-
.../dataregion/HashLastFlushTimeMap.java | 115 +-
.../dataregion/IDataRegionForQuery.java | 5 +-
.../dataregion/ILastFlushTimeMap.java | 31 +-
.../dataregion/VirtualDataRegion.java | 5 +-
.../fast/AlignedSeriesCompactionExecutor.java | 19 +-
.../fast/NonAlignedSeriesCompactionExecutor.java | 15 +-
.../executor/fast/SeriesCompactionExecutor.java | 46 +-
.../executor/fast/element/AlignedPageElement.java | 94 +
.../fast/element/NonAlignedPageElement.java | 74 +
.../utils/executor/fast/element/PageElement.java | 96 +-
.../utils/executor/fast/element/PointElement.java | 11 +-
.../fast/reader/CompactionAlignedChunkReader.java | 122 ++
.../fast/reader/CompactionChunkReader.java | 94 +
.../readchunk/SingleSeriesCompactionExecutor.java | 2 +-
.../execute/utils/reader/PointPriorityReader.java | 2 +-
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/DiskChunkLoader.java | 4 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 13 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 6 +-
.../read/reader/chunk/MemAlignedPageReader.java | 105 +-
.../read/reader/chunk/MemChunkLoader.java | 4 +-
.../read/reader/chunk/MemChunkReader.java | 13 +-
.../read/reader/chunk/MemPageReader.java | 267 +--
.../metadata/DiskAlignedChunkMetadataLoader.java | 57 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 48 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 40 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 31 +-
.../dataregion/snapshot/SnapshotTaker.java | 14 +-
.../dataregion/tsfile/TsFileResource.java | 8 +-
.../dataregion/utils/TsFileResourceUtils.java | 52 +-
.../file/AbstractTsFileRecoverPerformer.java | 4 +-
.../quotas/DataNodeThrottleQuotaManager.java | 2 +-
.../rescon/quotas/DefaultOperationQuota.java | 16 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 2 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../db/trigger/executor/TriggerFireVisitor.java | 17 +-
.../schemaRegion/SchemaRegionBasicTest.java | 42 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 15 +
.../schema/SchemaQueryScanOperatorTest.java | 6 +-
.../storageengine/dataregion/DataRegionTest.java | 48 +-
...InconsistentCompressionTypeAndEncodingTest.java | 4 +-
.../compaction/utils/CompactionCheckerUtils.java | 7 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 250 +++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 4 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 12 +-
.../read/reader/chunk/MemPageReaderTest.java | 134 ++
...est.java => AbstractAlignedSeriesScanTest.java} | 307 +--
.../read/reader/series/AbstractSeriesScanTest.java | 236 +++
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 404 +---
.../AlignedSeriesScanPredicatePushDownTest.java | 225 +++
...gleColumnSeriesScanLimitOffsetPushDownTest.java | 201 ++
.../series/SeriesScanLimitOffsetPushDownTest.java | 210 +-
.../series/SeriesScanPredicatePushDownTest.java | 318 +++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 4 +
.../datanode/src/test/resources/logback-test.xml | 1 +
.../resources/conf/iotdb-common.properties | 8 +-
.../iotdb/commons/client/ClientPoolFactory.java | 2 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 19 +-
.../iotdb/commons/conf/CommonDescriptor.java | 13 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../iotdb/commons/pipe/config/PipeConfig.java | 11 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 8 +-
.../builtin/connector/IoTDBThriftSslConnector.java | 18 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +
.../commons/schema/filter/SchemaFilterFactory.java | 5 +
.../commons/schema/filter/SchemaFilterType.java | 3 +
.../commons/schema/filter/SchemaFilterVisitor.java | 5 +
.../commons/schema/filter/impl/TemplateFilter.java | 73 +
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 3 +
.../tsfile/file/metadata/AlignedChunkMetadata.java | 2 +
.../file/metadata/AlignedTimeSeriesMetadata.java | 2 +
.../iotdb/tsfile/file/metadata/IMetadata.java | 8 +
.../apache/iotdb/tsfile/read/TimeValuePair.java | 20 +
.../read/TsFileAlignedSeriesReaderIterator.java | 3 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 5 +-
.../read/controller/CachedChunkLoaderImpl.java | 4 +-
.../iotdb/tsfile/read/controller/IChunkLoader.java | 3 +-
.../iotdb/tsfile/read/filter/basic/Filter.java | 9 +
.../iotdb/tsfile/read/filter/basic/TimeFilter.java | 10 +
.../tsfile/read/filter/basic/ValueFilter.java | 17 +
.../tsfile/read/filter/factory/FilterFactory.java | 21 +-
.../iotdb/tsfile/read/filter/operator/And.java | 11 +
.../iotdb/tsfile/read/filter/operator/Not.java | 10 +
.../iotdb/tsfile/read/filter/operator/Or.java | 11 +
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../read/reader/chunk/AbstractChunkReader.java | 83 +
.../read/reader/chunk/AlignedChunkReader.java | 470 ++---
.../tsfile/read/reader/chunk/ChunkReader.java | 235 +--
.../tsfile/read/reader/page/AlignedPageReader.java | 476 ++---
.../iotdb/tsfile/read/reader/page/PageReader.java | 390 ++--
.../read/reader/series/FileSeriesReader.java | 2 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 4 +-
.../read/reader/series/PaginationController.java | 1 -
.../read/reader/AlignedPageReaderPushDownTest.java | 322 +++
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 4 +-
.../tsfile/read/reader/PageReaderPushDownTest.java | 145 ++
.../iotdb/tsfile/read/reader/PageReaderTest.java | 6 +-
.../tsfile/write/TsFileIntegrityCheckingTool.java | 7 +-
.../src/main/thrift/confignode.thrift | 44 +-
pom.xml | 6 +
224 files changed, 9515 insertions(+), 4257 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterStartIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/GrafanaApiServiceIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRestServiceIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/confignode/UpdateClusterIdPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/PipeEnrichedPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterManager.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ClusterInfo.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/ClusterInfoTest.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteDataNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/config/plugin/env/PipeTaskTemporaryRuntimeEnvironment.java
(63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipePlanToStatementVisitor.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{utils =>
queryengine/execution/operator/source}/FileLoaderUtils.java (75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ShowClusterIdTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedConfigSchemaNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedDeleteDataNode.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/{write
=> pipe}/PipeEnrichedInsertNode.java (89%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/pipe/PipeEnrichedWriteSchemaNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedLoadTsFileStatement.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteDataNodeConfig.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/ShowClusterIdStatement.java
(59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/pipe/PipeEnrichedStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/AlignedPageElement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/NonAlignedPageElement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/reader/CompactionAlignedChunkReader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/reader/CompactionChunkReader.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/AlignedMemPageReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/MemPageReaderTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/{AlignedSeriesScanLimitOffsetPushDownTest.java
=> AbstractAlignedSeriesScanTest.java} (60%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AbstractSeriesScanTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AlignedSeriesScanPredicatePushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/AlignedSingleColumnSeriesScanLimitOffsetPushDownTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/series/SeriesScanPredicatePushDownTest.java
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteDataNodeConfig.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/IoTDBThriftSslConnector.java
(63%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/TemplateFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/AbstractChunkReader.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/AlignedPageReaderPushDownTest.java
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/PageReaderPushDownTest.java
