This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4a9fb924391 Fix file counted twice in TsFileMetrics (#11662)
add 3427b320b62 Fix compaction UTs and add concurrency control when
schedule compaction (#11638)
add f48454ab50a Update iotdb-doap.rdf
add 2edc91d287f Add format check for Prometheus Reporter Check (#11666)
add ec118416f36 Added getRegionId api for partitionManager (#11663)
add 24f0a606cbc Ignore MismatchedType caused by delete
add 788b0bc9523 Refactor Device Node Implementation in SchemaRegion
(#11661)
add dcaedd336e3 Extend `Filter` interface to support aligned timeseries
add 235a3f3c14e Pipe Schema: Added ConcurrentIterableLinkedQueue to record
the ConsensusRequest and SnapShot event (#11650)
add 5e89a90ece5 TopKNode will use IdentityNode but not ShuffleSinkNode
add 9b19cf72ac4 [IOTDB-6174] Support ColumnInjectOperator for '__endTime'
output
add 6c92fbc8c77 Optimize the efficiency of map-related code in
IRegionGroupAllocator (#11673)
add 78ce7e74bce [IOTDB-6259][RatisConsensus] Fix missing prefix in gauge
metrics (#11677)
add c185c6c9c92 [IOTDB-6263] Enhance IoTDBPartitionCreationIT (#11676)
add 0fa7f403130 Fix reconnect bug for JDBC
add 3b4788614c2 Pipe: avoid useless pipe meta sync (stopped status) to DN
to achieve high availability (#11641)
add 90ce01eb7e8 [RatisConsensus] Retry Read Requests on
StatusRuntimeException (#11679)
add 11adc7c920a [IOTDB-6252] Greedy CopySet allocation algorithm (#11572)
add ee5e23dbb94 Rest service code optimization and fixed insertRecords
error prompt returning null issue (#11678)
add 9ded0bdf7dd Bump ch.qos.logback:logback-core from 1.3.13 to 1.3.14
(#11683)
add 60d66ae873f Enhance the note of parameter seed_config_node (#11685)
add a93cf09d1bd Enhance the exapmle of parameter dn_seed_config_node
(#11686)
add c450e768980 Enhance parameter dn_seed_config_node commets order
(#11687)
add 4922dad4d17 Add last time check for inner space compaction task
(#11553)
add 9af1e765c5d Cache the internal compaction estimation result if
compaction task is failed to run (#11586)
add acde4457a3d [IOTDB-6264] Load: Optimized Validation Messages with
'write_data' Permissions When Loading TsFiles Without schema Creation (#11684)
add 09b7e86fd63 add config for inner compaction selector (#11693)
add b1d3dc63c9e [IOTDB-6265] Construct SessionPool using empty nodeUrls
should throw exception
add 5caeeb3e3b7 Pipe: automatically start pipe upon creation & allow to
start RUNNING pipe & allow to stop STOPPED pipe (#11690)
add a061c0d4514 Pipe: Make error message reported by pipe parameter check
clearer (#11695)
add b57f320153b Make slimit and soffset available in align by device with
template
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 16 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 1 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 1 +
.../it/partition/IoTDBPartitionCreationIT.java | 4 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 2 +-
.../IoTDBAlignByDeviceWithTemplateIT.java | 82 +++
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 196 +++++++
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 71 +++
.../iotdb/pipe/it/IoTDBPipeSwitchStatusIT.java | 22 +-
.../apache/iotdb/pipe/it/IoTDBPipeSyntaxIT.java | 2 +-
.../parameter/PipeParameterValidator.java | 6 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 15 +-
.../java/org/apache/iotdb/session/Session.java | 8 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 8 +-
.../java/org/apache/iotdb/session/SessionTest.java | 12 +
.../session/pool/SessionPoolExceptionTest.java | 12 +
.../iotdb/spark/tsfile/NarrowConverter.scala | 56 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 56 +-
.../resources/conf/iotdb-confignode.properties | 2 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../manager/load/balancer/RegionBalancer.java | 21 +-
.../region/CopySetRegionGroupAllocator.java | 160 -----
.../region/GreedyCopySetRegionGroupAllocator.java | 191 ++++++
.../region/GreedyRegionGroupAllocator.java | 31 +-
.../manager/partition/PartitionManager.java | 15 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 4 +-
.../manager/pipe/runtime/PipeMetaSyncer.java | 15 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 35 +-
.../partition/DatabasePartitionTable.java | 8 +
.../persistence/partition/PartitionInfo.java | 8 +
.../confignode/persistence/pipe/PipeTaskInfo.java | 28 +-
.../confignode/persistence/schema/ConfigMTree.java | 2 +-
.../persistence/schema/mnode/IConfigMNode.java | 28 +
.../schema/mnode/basic/ConfigBasicMNode.java | 50 +-
.../mnode/impl/ConfigBasicInternalMNode.java | 37 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 2 +
.../impl/pipe/task/StartPipeProcedureV2.java | 19 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 19 +-
.../GreedyCopySetRegionGroupAllocatorTest.java | 203 +++++++
.../confignode/persistence/PartitionInfoTest.java | 70 ++-
.../iotdb/consensus/ratis/RatisConsensus.java | 23 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 8 +-
.../resources/conf/iotdb-datanode.properties | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 42 ++
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 24 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 119 ++--
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 6 +-
.../tsfile/TsFileInsertionDataContainer.java | 6 +-
.../rest/v1/handler/RequestValidationHandler.java | 12 -
.../v1/handler/StatementConstructionHandler.java | 59 --
.../protocol/rest/v1/impl/RestApiServiceImpl.java | 47 --
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 36 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../execution/operator/AggregationUtil.java | 16 +-
.../operator/process/AggregationOperator.java | 19 +-
...fsetOperator.java => ColumnInjectOperator.java} | 79 ++-
.../process/SlidingWindowAggregationOperator.java | 18 +-
.../execution/operator/process/TopKOperator.java | 8 +-
.../AbstractSeriesAggregationScanOperator.java | 19 +-
.../AlignedSeriesAggregationScanOperator.java | 25 +
.../operator/source/AlignedSeriesScanUtil.java | 99 ++--
.../source/SeriesAggregationScanOperator.java | 25 +
.../execution/operator/source/SeriesScanUtil.java | 32 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 39 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 42 +-
.../ConvertPredicateToTimeFilterVisitor.java | 30 +-
.../plan/optimization/LimitOffsetPushDown.java | 11 +-
.../plan/optimization/PlanNodePushDown.java | 76 +++
.../base/ColumnInjectionPushDown.java} | 7 +-
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../plan/planner/LogicalPlanVisitor.java | 12 +
.../plan/planner/OperatorTreeGenerator.java | 60 +-
.../planner/distribution/DistributionPlanner.java | 36 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 13 +
.../plan/planner/plan/node/PlanNodeType.java | 6 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../planner/plan/node/process/AggregationNode.java | 8 +-
.../plan/node/process/ColumnInjectNode.java | 123 ++++
.../node/process/SlidingWindowAggregationNode.java | 56 +-
.../source/AlignedSeriesAggregationScanNode.java | 34 +-
.../node/source/SeriesAggregationScanNode.java | 34 +-
.../node/source/SeriesAggregationSourceNode.java | 37 +-
.../planner/plan/node/write/DeleteDataNode.java | 4 +-
.../planner/plan/parameter/SeriesScanOptions.java | 7 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 28 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 23 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 26 +-
.../impl/mem/mnode/factory/MemMNodeFactory.java | 11 +-
.../impl/mem/mnode/impl/BasicInternalMNode.java | 83 +--
.../impl/mem/mnode/impl/DatabaseDeviceMNode.java | 37 --
.../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 17 +-
.../mtree/impl/mem/mnode/impl/DeviceMNode.java | 36 --
.../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 2 +-
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 75 +--
.../mtree/impl/pbtree/CachedMTreeStore.java | 43 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 28 +-
.../impl/pbtree/mnode/basic/CachedBasicMNode.java | 25 +-
.../pbtree/mnode/factory/CacheMNodeFactory.java | 11 +-
.../mnode/impl/CachedBasicInternalMNode.java | 91 +--
.../mnode/impl/CachedDatabaseDeviceMNode.java | 49 --
.../pbtree/mnode/impl/CachedDatabaseMNode.java | 18 +-
.../impl/pbtree/mnode/impl/CachedDeviceMNode.java | 48 --
.../schemaregion/utils/MNodeUtils.java | 54 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +
...=> CompactionLastTimeCheckFailedException.java} | 16 +-
.../execute/task/AbstractCompactionTask.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 8 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 12 +
.../readchunk/SingleSeriesCompactionExecutor.java | 13 +
.../utils/writer/AbstractCompactionWriter.java | 11 +
.../writer/AbstractCrossCompactionWriter.java | 11 +-
.../writer/AbstractInnerCompactionWriter.java | 2 +
.../utils/writer/FastInnerCompactionWriter.java | 4 +
.../compaction/schedule/CompactionScheduler.java | 13 +
.../compaction/schedule/CompactionWorker.java | 9 +-
.../estimator/AbstractCompactionEstimator.java | 27 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../impl/SizeTieredCompactionSelector.java | 8 +-
.../compaction/settle/SettleRequestHandler.java | 24 +-
.../read/reader/chunk/MemAlignedPageReader.java | 78 ++-
.../read/reader/chunk/MemPageReader.java | 32 +-
.../columngenerator/ColumnGenerator.java} | 8 +-
.../columngenerator/ColumnGeneratorType.java} | 18 +-
.../SlidingTimeColumnGenerator.java | 52 ++
.../parameter/ColumnGeneratorParameter.java | 82 +++
.../SlidingTimeColumnGeneratorParameter.java | 80 +++
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 31 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../operator/AggregationOperatorTest.java | 1 +
.../AlignedSeriesAggregationScanOperatorTest.java | 12 +-
.../execution/operator/OperatorMemoryTest.java | 2 +
.../operator/RawDataAggregationOperatorTest.java | 4 +-
.../SeriesAggregationScanOperatorTest.java | 12 +-
.../SlidingWindowAggregationOperatorTest.java | 1 +
.../operator/UpdateLastCacheOperatorTest.java | 6 +-
.../ConvertPredicateToTimeFilterTest.java | 46 +-
.../plan/analyze/QueryTimePartitionTest.java | 108 ++--
.../plan/optimization/LimitOffsetPushDownTest.java | 10 +-
.../plan/plan/QueryLogicalPlanUtil.java | 8 +-
.../distribution/AggregationDistributionTest.java | 3 +-
.../compaction/CompactionOverlapCheckTest.java | 269 +++++++++
.../compaction/CompactionSchedulerTest.java | 25 +-
.../ReadPointCompactionPerformerTest.java | 2 +-
.../utils/CompactionUpdateFileCountTest.java | 2 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 9 +-
iotdb-core/node-commons/pom.xml | 5 +
.../resources/conf/iotdb-common.properties | 10 +-
.../ConcurrentIterableLinkedQueue.java | 345 +++++++++++
.../apache/iotdb/commons/schema/node/IMNode.java | 12 +-
.../node/common/AbstractAboveDatabaseMNode.java | 18 +-
.../node/common/AbstractDatabaseDeviceMNode.java | 299 ----------
.../schema/node/common/AbstractDatabaseMNode.java | 26 +-
.../node/common/AbstractMeasurementMNode.java | 19 +-
...actDeviceMNode.java => DeviceMNodeWrapper.java} | 130 ++---
.../commons/schema/node/role/IDeviceMNode.java | 2 +-
.../commons/schema/node/role/IInternalMNode.java} | 35 +-
.../commons/schema/node/visitor/MNodeVisitor.java | 7 -
.../ConcurrentIterableLinkedQueueTest.java | 439 ++++++++++++++
.../pipe/{ => task/meta}/PipeMetaDeSerTest.java | 7 +-
.../iotdb/tsfile/file/header/ChunkGroupHeader.java | 2 +-
.../iotdb/tsfile/file/header/PageHeader.java | 23 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 42 +-
.../file/metadata/AlignedTimeSeriesMetadata.java | 57 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 22 +
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 6 +-
.../metadata/IMetadata.java} | 15 +-
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 9 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 31 +
.../apache/iotdb/tsfile/read/common/TimeRange.java | 10 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 32 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 7 +-
.../base => basic}/BinaryLogicalFilter.java | 10 +-
...ilter.java => DisableStatisticsTimeFilter.java} | 8 +-
...lter.java => DisableStatisticsValueFilter.java} | 21 +-
.../iotdb/tsfile/read/filter/basic/Filter.java | 71 ++-
.../tsfile/read/filter/basic/IStatefulFilter.java | 32 -
.../tsfile/read/filter/basic/ITimeFilter.java | 33 --
.../tsfile/read/filter/basic/IValueFilter.java | 40 --
.../tsfile/read/filter/basic/OperatorType.java | 68 ++-
.../iotdb/tsfile/read/filter/basic/TimeFilter.java | 58 ++
.../tsfile/read/filter/basic/ValueFilter.java | 120 ++++
.../{TimeFilter.java => TimeFilterApi.java} | 4 +-
.../tsfile/read/filter/factory/ValueFilter.java | 168 ------
.../tsfile/read/filter/factory/ValueFilterApi.java | 186 ++++++
.../iotdb/tsfile/read/filter/operator/And.java | 19 +-
.../tsfile/read/filter/operator/GroupByFilter.java | 8 +-
.../read/filter/operator/GroupByMonthFilter.java | 7 +-
.../iotdb/tsfile/read/filter/operator/Not.java | 30 +-
.../iotdb/tsfile/read/filter/operator/Or.java | 19 +-
.../read/filter/operator/TimeFilterOperators.java | 196 +++----
.../read/filter/operator/ValueFilterOperators.java | 649 +++++++++++++--------
.../filter/operator/base/ColumnCompareFilter.java | 51 --
.../operator/base/ColumnPatternMatchFilter.java | 50 --
.../filter/operator/base/ColumnRangeFilter.java | 51 --
.../read/filter/operator/base/ColumnSetFilter.java | 50 --
.../iotdb/tsfile/read/reader/IPageReader.java | 7 +-
.../read/reader/chunk/AlignedChunkReader.java | 34 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 14 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 101 ++--
.../iotdb/tsfile/read/reader/page/PageReader.java | 40 +-
.../tsfile/read/reader/page/ValuePageReader.java | 3 +-
.../reader/series/AbstractFileSeriesReader.java | 16 +-
.../read/reader/series/EmptyFileSeriesReader.java | 4 +-
.../read/reader/series/FileSeriesReader.java | 4 +-
.../apache/iotdb/tsfile/utils/Preconditions.java | 22 +-
.../iotdb/tsfile/common/block/TsBlockTest.java | 77 +++
.../apache/iotdb/tsfile/read/ExpressionTest.java | 36 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 8 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 60 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 64 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 66 +--
.../tsfile/read/filter/FilterSerializeTest.java | 70 +--
.../iotdb/tsfile/read/filter/FilterTestUtil.java | 105 ++++
.../tsfile/read/filter/GroupByFilterTest.java | 33 +-
.../tsfile/read/filter/GroupByMonthFilterTest.java | 35 +-
.../read/filter/IExpressionOptimizerTest.java | 83 +--
.../read/filter/MinTimeMaxTimeFilterTest.java | 70 +--
.../iotdb/tsfile/read/filter/OperatorTest.java | 95 ++-
.../filter/PredicateRemoveNotRewriterTest.java | 62 +-
.../tsfile/read/filter/StatisticsFilterTest.java | 300 ++++++----
.../read/query/executor/QueryExecutorTest.java | 11 +-
.../read/query/timegenerator/ReadWriteTest.java | 10 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 10 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 10 +-
.../query/timegenerator/TimeGeneratorTest.java | 10 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 8 +-
iotdb-doap.rdf | 33 ++
.../openapi/src/main/openapi3/iotdb_rest_v1.yaml | 52 --
pom.xml | 2 +-
231 files changed, 6174 insertions(+), 3635 deletions(-)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/CopySetRegionGroupAllocator.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRegionGroupAllocator.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRegionGroupAllocatorTest.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{OffsetOperator.java
=> ColumnInjectOperator.java} (54%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/PlanNodePushDown.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/auth/AuthOperationProcedureState.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/optimization/base/ColumnInjectionPushDown.java}
(84%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/ColumnInjectNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/impl/DatabaseDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/impl/DeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/impl/CachedDatabaseDeviceMNode.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/pbtree/mnode/impl/CachedDeviceMNode.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/{CompactionRecoverException.java
=> CompactionLastTimeCheckFailedException.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution/operator/process/fill/IFill.java
=> utils/columngenerator/ColumnGenerator.java} (79%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/ClusterSchemaQuotaLevel.java
=>
datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/ColumnGeneratorType.java}
(77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/SlidingTimeColumnGenerator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/parameter/ColumnGeneratorParameter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/columngenerator/parameter/SlidingTimeColumnGeneratorParameter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionOverlapCheckTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/ConcurrentIterableLinkedQueue.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDatabaseDeviceMNode.java
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/{AbstractDeviceMNode.java
=> DeviceMNodeWrapper.java} (65%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/iterator/MNodeIterator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/role/IInternalMNode.java}
(56%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/ConcurrentIterableLinkedQueueTest.java
rename iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/{
=> task/meta}/PipeMetaDeSerTest.java (94%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/{read/reader/IAlignedPageReader.java
=> file/metadata/IMetadata.java} (69%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/{operator/base
=> basic}/BinaryLogicalFilter.java (85%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/{IDisableStatisticsTimeFilter.java
=> DisableStatisticsTimeFilter.java} (79%)
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/{IDisableStatisticsValueFilter.java
=> DisableStatisticsValueFilter.java} (65%)
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/IStatefulFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/ITimeFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/IValueFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/TimeFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/ValueFilter.java
rename
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/{TimeFilter.java
=> TimeFilterApi.java} (98%)
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/ValueFilter.java
create mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/ValueFilterApi.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnCompareFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnPatternMatchFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnRangeFilter.java
delete mode 100644
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/operator/base/ColumnSetFilter.java
copy example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.java =>
iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/Preconditions.java
(66%)
create mode 100644
iotdb-core/tsfile/src/test/java/org/apache/iotdb/tsfile/read/filter/FilterTestUtil.java
