This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira5324
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 5b8cfd36f8 finish
add c085fb1a8c [IOTDB-4005] Pipeline fragmentInstance to implement
parallel execution
add 27549169a3 [IOTDB-5384] add
core_client_count_for_each_node_in_client_manager and
max_client_count_for_each_node_in_client_manager parameters for confignode and
datanode （#8800）
add a1cc705fdd [IOTDB-5387] Refine IT: Make JVM parameters mutable easily
(#8795)
add 7b1977330a [IOTDB-5328] Rename "REMOVE_DATANODE_PROCESS" in
MIGRATE_REGION_PROCEDURE to "REGION_MIGRATE_PROCESS" (#8790)
add 76d3a13e29 Eliminate LocalSchemaProcessor and stale code (#8802)
add 4dcaf696d5 Eliminate LocalConfigNode and Fix NPE while forceMLog
(#8804)
add dfb013b710 Separate SYNC_CONNECTION_ERROR and DISPATCH_ERROR (#8726)
add 8e40479c42 [IOTDB-5288][IOTDB-5163] Fix the file metrics is wrong
(#8805)
add 5ad3384f0f Change config in SourceHandleTest according to
IoTDBDescriptor
add 44fb69a7ff Fix wal manager test (#8808)
add 5dac205243 [IOTDB-4437] Implement event window in
RawDataAggregationOperator
add 43cd37bdcf [IOTDB-5389] Cause DataNode startup to fail when wal_mode
is disabled in IoTConsensus (#8798)
add 3ddaa39983 [IOTDB-5391] Implement SchemaReader using iterative
Traverser (#8816)
add 4f1409df4d Fix testGetSlots bug (#8819)
add ee93ad4145 [IOTDB-4960]SchemaFile implements separate FileChannel for
read/write operation (#8813)
add 8224a70a41 [IOTDB-5398] Handle failure in schema query if there is
exception occurs during the iteration (#8830)
add 309206e504 [IOTDB-5392] accelerate pointPriorityReader in fast
compaction
add 3c01a93437 [IOTDB-5401] Reduce the estimated size of memory retained
after calling next in SeriesAggregationScanOperator
add b93dbfa5e6 [IOTDB-5369] Add query related panels in Grafana Dashboard
(#8764)
add 4ee81d4d68 [IOTDB-5345] Use the logical clock to identify the snapshot
version of IoTConsensus (#8807)
add a009560f26 [IOTDB-5390] Keep mqtt_host same with rpc_address (#8831)
add 2122ae3353 [IOTDB-5404] Fix concurrency problem of metricSets in
AbstractMetricService (#8841)
add 4a73e612d3 Fix mqtt docs (#8845)
add df26f54db3 [IOTDB-5403] Refine IT: Add ensureNodeStatus to test status
after starting or stopping (#8844)
add ed75dfcc81 finish (#8837)
add 0d66e3baf5 finish
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5b8cfd36f8)
\
N -- N -- N refs/heads/jira5324 (0d66e3baf5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../impl/statemachine/RegionMigrateProcedure.java | 15 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 1 +
.../consensus/iot/IoTConsensusServerImpl.java | 86 +-
.../consensus/iot/IoTConsensusServerMetrics.java | 2 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 2 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 32 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 55 +-
docs/UserGuide/API/Programming-MQTT.md | 6 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 15015 +++++++++++++++----
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 31 +
docs/UserGuide/Reference/Status-Codes.md | 15 +-
docs/zh/UserGuide/API/Programming-MQTT.md | 6 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 31 +
docs/zh/UserGuide/Reference/Status-Codes.md | 249 +-
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 79 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 43 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 19 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 9 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 25 +-
.../iotdb/it/env/cluster/MppClusterConfig.java | 15 +
.../apache/iotdb/it/env/cluster/MppJVMConfig.java | 116 +
.../iotdb/it/env/remote/RemoteClusterConfig.java | 12 +
.../env/remote/RemoteJVMConfig.java} | 34 +-
.../iotdb/it/env/remote/RemoteServerEnv.java | 7 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 13 +
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 2 -
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 30 +-
.../env/{BaseNodeWrapper.java => JVMConfig.java} | 47 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 66 +-
.../it/cluster/IoTDBClusterRestartIT.java | 3 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 28 +-
.../it/partition/IoTDBPartitionDurableIT.java | 24 +-
.../it/partition/IoTDBPartitionGetterIT.java | 94 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 3 -
.../iotdb/metrics/AbstractMetricService.java | 3 +-
.../resources/conf/iotdb-common.properties | 2 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 2 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 4 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 62 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 48 +-
.../resources/conf/iotdb-datanode.properties | 9 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 6 +
.../execute/task/CrossSpaceCompactionTask.java | 27 +-
.../execute/task/InnerSpaceCompactionTask.java | 29 +-
.../execute/utils/reader/PointPriorityReader.java | 14 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 294 -
.../db/localconfignode/LocalDataPartitionInfo.java | 111 -
.../localconfignode/LocalDataPartitionTable.java | 127 -
.../localconfignode/LocalSchemaPartitionTable.java | 122 -
.../iotdb/db/metadata/LocalSchemaProcessor.java | 250 -
.../iotdb/db/metadata/mtree/ConfigMTree.java | 21 -
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 4 -
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 221 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 182 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 21 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 5 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 17 +-
.../traverser/TraverserWithLimitOffsetWrapper.java | 10 +
.../schemaregion/result/ShowTimeSeriesResult.java | 10 +-
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 5 +-
.../db/metadata/query/reader/ISchemaReader.java | 16 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 65 +-
.../db/metadata/schemaregion/SchemaEngine.java | 3 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 109 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 126 +-
.../storagegroup/IStorageGroupSchemaManager.java | 53 -
.../storagegroup/StorageGroupSchemaManager.java | 78 -
.../apache/iotdb/db/metadata/tag/TagManager.java | 3 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 4 +-
.../db/mpp/aggregation/ExtremeAccumulator.java | 8 +-
.../db/mpp/aggregation/FirstValueAccumulator.java | 12 +-
.../mpp/aggregation/FirstValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/LastValueAccumulator.java | 12 +-
.../mpp/aggregation/LastValueDescAccumulator.java | 12 +-
.../db/mpp/aggregation/MaxTimeAccumulator.java | 2 +-
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MaxValueAccumulator.java | 8 +-
.../db/mpp/aggregation/MinTimeAccumulator.java | 2 +-
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 2 +-
.../db/mpp/aggregation/MinValueAccumulator.java | 8 +-
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 8 +-
.../iotdb/db/mpp/execution/StateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 37 +-
.../db/mpp/execution/driver/DataDriverContext.java | 48 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 34 +-
.../db/mpp/execution/driver/DriverContext.java | 76 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 5 +-
.../db/mpp/execution/driver/SchemaDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 13 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 25 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 27 +-
.../execution/exchange/MPPDataExchangeManager.java | 113 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 5 +
.../db/mpp/execution/exchange/SinkHandle.java | 2 +-
.../db/mpp/execution/exchange/SourceHandle.java | 2 +-
.../fragment/FragmentInstanceContext.java | 127 +-
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 37 +-
.../db/mpp/execution/operator/OperatorContext.java | 32 +-
.../operator/factory/OperatorFactory.java} | 26 +-
.../operator/factory/SourceOperatorFactory.java} | 24 +-
.../process/RawDataAggregationOperator.java | 51 +-
.../process/SingleInputAggregationOperator.java | 12 +-
.../process/SlidingWindowAggregationOperator.java | 11 +
.../operator/process/join/TimeJoinOperator.java | 1 -
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelScanOperator.java | 6 +-
.../operator/schema/SchemaCountOperator.java | 6 +-
.../operator/schema/SchemaQueryScanOperator.java | 8 +-
.../schema/source/PathsUsingTemplateSource.java | 26 +
.../schema/source/TimeSeriesSchemaSource.java | 5 +-
.../AbstractSeriesAggregationScanOperator.java | 8 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../operator/source/ExchangeOperator.java | 4 +
.../operator/source/SeriesScanOperator.java | 76 +-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../operator/window/EqualEventBooleanWindow.java} | 25 +-
.../window/EqualEventBooleanWindowManager.java | 64 +
.../operator/window/EqualEventDoubleWindow.java} | 25 +-
.../window/EqualEventDoubleWindowManager.java | 64 +
.../operator/window/EqualEventFloatWindow.java} | 25 +-
.../window/EqualEventFloatWindowManager.java | 64 +
.../operator/window/EqualEventIntWindow.java} | 25 +-
.../window/EqualEventIntWindowManager.java | 63 +
.../operator/window/EqualEventLongWindow.java} | 25 +-
.../window/EqualEventLongWindowManager.java | 63 +
.../operator/window/EqualEventTextWindow.java} | 25 +-
.../window/EqualEventTextWindowManager.java | 64 +
.../operator/window/EventBooleanWindow.java | 66 +
.../operator/window/EventBooleanWindowManager.java | 46 +
.../operator/window/EventDoubleWindow.java | 66 +
.../operator/window/EventDoubleWindowManager.java | 46 +
.../operator/window/EventFloatWindow.java | 66 +
.../operator/window/EventFloatWindowManager.java | 46 +
.../execution/operator/window/EventIntWindow.java | 66 +
.../operator/window/EventIntWindowManager.java | 46 +
.../execution/operator/window/EventLongWindow.java | 66 +
.../operator/window/EventLongWindowManager.java | 46 +
.../execution/operator/window/EventTextWindow.java | 67 +
.../operator/window/EventTextWindowManager.java | 46 +
.../window/{TimeWindow.java => EventWindow.java} | 61 +-
.../operator/window/EventWindowManager.java | 138 +
.../operator/window/EventWindowParameter.java | 61 +
.../db/mpp/execution/operator/window/IWindow.java | 2 +-
.../execution/operator/window/IWindowManager.java | 68 +-
.../mpp/execution/operator/window/TimeWindow.java | 2 +-
.../operator/window/TimeWindowManager.java | 73 +-
.../operator/window/TimeWindowParameter.java} | 14 +-
.../window/VariationEventDoubleWindow.java} | 25 +-
.../window/VariationEventDoubleWindowManager.java | 66 +
.../window/VariationEventFloatWindow.java} | 25 +-
.../window/VariationEventFloatWindowManager.java | 66 +
.../operator/window/VariationEventIntWindow.java} | 25 +-
.../window/VariationEventIntWindowManager.java | 66 +
.../operator/window/VariationEventLongWindow.java} | 25 +-
.../window/VariationEventLongWindowManager.java | 66 +
.../operator/window/WindowManagerFactory.java | 84 +
.../operator/window/WindowParameter.java} | 23 +-
.../execution/operator/window/WindowType.java} | 20 +-
.../execution/schedule/AbstractDriverThread.java | 9 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 143 +-
...eption.java => DriverTaskAbortedException.java} | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 12 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/IDriverScheduler.java | 7 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 44 +-
.../task/{DriverTaskID.java => DriverTaskId.java} | 49 +-
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 81 +-
.../plan/planner/LocalExecutionPlanContext.java | 175 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 100 +-
.../plan/planner/MemoryDistributionCalculator.java | 472 -
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 276 +-
.../db/mpp/plan/planner/PipelineDriverFactory.java | 59 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 158 -
.../compaction/FastAlignedCrossCompactionTest.java | 134 +
.../FastNonAlignedCrossCompactionTest.java | 138 +
.../compaction/TestUtilsForAlignedSeries.java | 42 +-
.../db/engine/compaction/cross/MergeTest.java | 19 -
.../inner/AbstractInnerSpaceCompactionTest.java | 19 -
.../inner/FastCompactionPerformerAlignedTest.java | 3 -
...nerSeqCompactionWithReadChunkPerformerTest.java | 17 -
...rUnseqCompactionWithReadPointPerformerTest.java | 19 -
.../ReadChunkCompactionPerformerAlignedTest.java | 3 -
.../inner/sizetiered/SizeTieredCompactionTest.java | 19 -
.../recover/SizeTieredCompactionRecoverTest.java | 16 -
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 -
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 6 -
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 12 -
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 32 +-
.../schemaRegion/SchemaRegionBasicTest.java | 45 +-
.../schemaRegion/SchemaRegionManagementTest.java | 43 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 10 +-
.../schemaRegion/SchemaRegionTestUtil.java | 36 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 52 +-
.../execution/exchange/LocalSinkHandleTest.java | 26 +-
.../execution/exchange/LocalSourceHandleTest.java | 12 +-
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../mpp/execution/exchange/SourceHandleTest.java | 82 +-
.../operator/AggregationOperatorTest.java | 17 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 9 +-
.../operator/AlignedSeriesScanOperatorTest.java | 92 +-
.../execution/operator/AlignedSeriesTestUtil.java | 53 -
.../operator/DeviceMergeOperatorTest.java | 77 +-
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
.../mpp/execution/operator/FillOperatorTest.java | 17 +-
.../operator/LastQueryMergeOperatorTest.java | 25 +-
.../execution/operator/LastQueryOperatorTest.java | 49 +-
.../operator/LastQuerySortOperatorTest.java | 49 +-
.../mpp/execution/operator/LimitOperatorTest.java | 22 +-
.../execution/operator/LinearFillOperatorTest.java | 57 +-
.../execution/operator/MergeSortOperatorTest.java | 205 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 73 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 88 +-
.../operator/RawDataAggregationOperatorTest.java | 549 +-
.../SeriesAggregationScanOperatorTest.java | 8 +-
.../execution/operator/SeriesScanOperatorTest.java | 8 +-
.../operator/SingleDeviceViewOperatorTest.java | 20 +-
.../SlidingWindowAggregationOperatorTest.java | 12 +-
.../execution/operator/TimeJoinOperatorTest.java | 56 +-
.../operator/UpdateLastCacheOperatorTest.java | 13 +-
.../operator/VerticallyConcatOperatorTest.java | 14 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 110 +-
.../operator/schema/SchemaCountOperatorTest.java | 111 +-
.../operator/schema/SchemaOperatorTestUtil.java | 66 +
.../schema/SchemaQueryScanOperatorTest.java | 104 +-
.../schedule/DefaultDriverSchedulerTest.java | 166 +-
.../execution/schedule/DriverSchedulerTest.java | 45 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../schedule/queue/L1PriorityQueueTest.java | 6 +-
.../schedule/queue/L2PriorityQueueTest.java | 12 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 18 +
.../iotdb/db/rescon/ResourceManagerTest.java | 19 -
.../DataNodeInternalRPCServiceImplTest.java | 11 +-
.../db/sync/datasource/PipeOpManagerTest.java | 3 -
.../apache/iotdb/db/utils/EnvironmentUtils.java | 7 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 22 +-
.../db/wal/recover/WALRecoverManagerTest.java | 32 -
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 53 -
.../file/UnsealedTsFileRecoverPerformerTest.java | 31 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 3 -
259 files changed, 18384 insertions(+), 7847 deletions(-)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppJVMConfig.java
copy
integration-test/src/main/java/org/apache/iotdb/{itbase/env/BaseNodeWrapper.java
=> it/env/remote/RemoteJVMConfig.java} (67%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/env/{BaseNodeWrapper.java
=> JVMConfig.java} (52%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalConfigNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalDataPartitionTable.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/localconfignode/LocalSchemaPartitionTable.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaProcessor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/IStorageGroupSchemaManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupSchemaManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/factory/OperatorFactory.java} (58%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/factory/SourceOperatorFactory.java} (58%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventBooleanWindow.java} (62%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventBooleanWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventDoubleWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventDoubleWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventFloatWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventFloatWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventIntWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventIntWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventLongWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventLongWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/EqualEventTextWindow.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EqualEventTextWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventBooleanWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventBooleanWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventDoubleWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventDoubleWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventFloatWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventFloatWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventIntWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventIntWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventLongWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventLongWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventTextWindow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventTextWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{TimeWindow.java
=> EventWindow.java} (54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/EventWindowParameter.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java
=> mpp/execution/operator/window/TimeWindowParameter.java} (71%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventDoubleWindow.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventDoubleWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventFloatWindow.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventFloatWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventIntWindow.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventIntWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/VariationEventLongWindow.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/VariationEventLongWindowManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/WindowManagerFactory.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/info/ITimeSeriesSchemaInfo.java
=> mpp/execution/operator/window/WindowParameter.java} (65%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/query/reader/ISchemaReader.java
=> mpp/execution/operator/window/WindowType.java} (70%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java
=> DriverTaskAbortedException.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java
=> DriverTaskId.java} (56%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/PipelineDriverFactory.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/MetadataManagerHelper.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaOperatorTestUtil.java
