This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/packageRefactor
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0b11bcee0e5 done
add 379f2c713c2 Fix sonar check in schema module (#10297)
add 453f19930ac Fix sonar bugs and code smells in iotdb/db/metadata/metric
(#10264)
add ea911e4284f Fix sonar bugs and code smells in
mpp/execution/operator/schema (#10303)
add 1e35786c7e7 UDF: fix bugs & smells reported by SonarCloud
(org.apache.iotdb.library) (#10289)
add 268c6b88f92 [IOTDB-6017] Pipe: separate pipe heartbeat from cluster
heartbeat (#10285)
add 3bdb5d2cf52 fix code smells in settle package (#10293)
add 4c87bf3d352 Fix bugs and code smells in the sonarcloud (#10291)
add 102364b99f6 Refactor SchemaScanOperator to do asynchronous fetch and
return isBlock (#10231) (#10304)
add a62d48e5097 fix bugs and code smells of dir:engine/triggeră
engine/upgrade and engine/version (#10313)
add f2b78558a1f fix bugs and code smells of dir:engine/memtable (#10306)
add 9568967840b [IOTDB-5995] Fix SonerLint bugs in consensus module
(#10314)
add e7a6433d6d1 iotdb-connector: fix bugs & smells reported by SonarCloud
(#10310)
add 6ff4d7e52a1 [IOTDB-6025] iotdb-api: fix bugs & smells reported by
SonarCloud (#10318)
add b0a4ddae374 fix bugs and code smells of dir:engine/load (#10305)
add dc931102e48 fix bugs and code smells of dir:engine/flush and
engine/cache (#10300)
new 079b7dce44a resolve conflicts
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/external/api/IPropertiesLoader.java | 5 +-
.../external/api/thrift/JudgableServerContext.java | 9 +-
.../external/api/thrift/ServerContextFactory.java | 1 +
.../java/org/apache/iotdb/pipe/api/access/Row.java | 11 +-
.../event/dml/insertion/TabletInsertionEvent.java | 8 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 2 +-
.../org/apache/iotdb/pipe/api/type/Binary.java | 3 +-
.../java/org/apache/iotdb/pipe/api/type/Type.java | 18 +-
.../api/SubscriptionConfiguration.java | 4 +-
.../iotdb/subscription/api/consumer/Consumer.java | 12 +-
.../api/strategy/SubscriptionStrategy.java | 6 +-
.../api/strategy/disorder/IntolerableStrategy.java | 4 +-
.../java/org/apache/iotdb/trigger/api/Trigger.java | 2 +
.../iotdb/trigger/api/enums/FailureStrategy.java | 1 +
.../main/java/org/apache/iotdb/udf/api/UDF.java | 8 +-
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 21 +-
.../java/org/apache/iotdb/udf/api/access/Row.java | 10 +-
.../api/customizer/config/UDTFConfigurations.java | 10 +-
.../parameter/UDFParameterValidator.java | 4 +
.../api/customizer/strategy/AccessStrategy.java | 36 +++-
.../strategy/MappableRowByRowAccessStrategy.java | 20 +-
.../strategy/RowByRowAccessStrategy.java | 14 +-
.../strategy/SessionTimeWindowAccessStrategy.java | 2 +
.../strategy/SlidingSizeWindowAccessStrategy.java | 16 +-
.../strategy/SlidingTimeWindowAccessStrategy.java | 53 +++--
.../strategy/StateWindowAccessStrategy.java | 5 +
.../java/org/apache/iotdb/udf/api/type/Binary.java | 4 +-
.../java/org/apache/iotdb/udf/api/type/Type.java | 19 +-
.../iotdb/flink/DefaultIoTSerializationSchema.java | 2 +
.../java/org/apache/iotdb/flink/IoTDBSink.java | 4 +-
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 7 +-
.../iotdb/flink/tsfile/RowTSRecordConverter.java | 2 +-
.../iotdb/flink/tsfile/TsFileOutputFormat.java | 4 +-
.../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 1 +
.../controller/DatabaseConnectController.java | 4 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 5 +-
.../web/grafana/dao/impl/BasicDaoImplTest.java | 9 +-
.../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 2 +
.../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 10 +-
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 9 +-
.../iotdb/hadoop/tsfile/TSFOutputFormat.java | 4 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 4 +-
.../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 3 +-
.../java/org/apache/iotdb/hive/TsFileSerDe.java | 4 -
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 1 +
.../iotdb/spark/tsfile/qp/QueryProcessor.java | 21 +-
.../spark/tsfile/qp/common/FilterOperator.java | 10 +-
.../iotdb/spark/tsfile/qp/common/SQLConstant.java | 119 +++++------
.../qp/exception/QueryProcessorException.java | 2 +-
.../tsfile/qp/optimizer/DNFFilterOptimizer.java | 15 +-
.../qp/optimizer/MergeSingleFilterOptimizer.java | 10 -
.../tsfile/qp/optimizer/PhysicalOptimizer.java | 22 +-
.../tsfile/qp/optimizer/RemoveNotOptimizer.java | 5 -
.../iotdb/spark/tsfile/NarrowConverter.scala | 4 +-
.../confignode/client/DataNodeRequestType.java | 1 +
.../client/async/AsyncDataNodeClientPool.java | 8 +
.../client/async/handlers/AsyncClientHandler.java | 10 +
...PCHandler.java => PipeHeartbeatRPCHandler.java} | 40 +---
.../statemachine/ConfigRegionStateMachine.java | 3 +
.../manager/load/service/HeartbeatService.java | 8 +-
.../pipe/runtime/PipeHeartbeatScheduler.java | 111 ++++++++++
.../pipe/runtime/PipeLeaderChangeHandler.java | 15 +-
.../pipe/runtime/PipeRuntimeCoordinator.java | 24 ++-
.../confignode/persistence/pipe/PipeTaskInfo.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 18 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 8 +
.../iotdb/consensus/ratis/RequestMessage.java | 14 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 14 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 2 +-
.../metadata/AlignedTimeseriesException.java | 4 -
.../metadata/DataTypeMismatchException.java | 14 +-
.../metadata/DuplicateInsertException.java | 1 +
.../metadata/IllegalParameterOfPathException.java | 1 +
.../metadata/MNodeTypeMismatchException.java | 1 +
.../metadata/MeasurementAlreadyExistException.java | 2 +-
.../SchemaDirCreationFailureException.java | 1 +
.../metadata/SchemaExecutionException.java} | 12 +-
.../metadata/SchemaQuotaExceededException.java | 6 +-
.../metadata/SeriesNumberOverflowException.java | 29 ---
.../metadata/SeriesOverflowException.java | 6 +-
.../metadata/cache/MNodeNotCachedException.java | 1 +
.../schemafile/ColossalRecordException.java | 1 +
.../template/TemplateImcompatibeException.java | 3 +-
.../metadata/view/BrokenViewException.java | 5 +-
.../view/InsertNonWritableViewException.java | 1 +
.../metadata/view/UnsupportedViewException.java | 1 +
.../view/ViewContainsAggregationException.java | 1 +
.../metadata/view/ViewNotExistException.java | 1 +
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 22 ++
.../impl/DataNodeInternalRPCServiceImpl.java | 9 +
.../common/schematree/ClusterSchemaTree.java | 15 +-
.../common/schematree/DeviceSchemaInfo.java | 14 +-
.../common/schematree/IMeasurementSchemaInfo.java | 6 +-
.../queryengine/common/schematree/ISchemaTree.java | 4 +-
.../schematree/node/SchemaMeasurementNode.java | 7 +-
.../common/schematree/node/SchemaNode.java | 4 +-
.../visitor/SchemaTreeVisitorFactory.java | 1 +
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 1 +
.../execution/load/AlignedChunkData.java | 70 +++---
.../execution/load/LoadTsFileManager.java | 36 ++--
.../execution/load/NonAlignedChunkData.java | 53 +++--
.../queryengine/execution/load/TsFileSplitter.java | 5 +-
.../schema/CountGroupByLevelMergeOperator.java | 6 +-
.../schema/CountGroupByLevelScanOperator.java | 109 +++++++---
.../operator/schema/CountMergeOperator.java | 21 +-
.../schema/NodeManageMemoryMergeOperator.java | 2 +-
.../operator/schema/SchemaCountOperator.java | 76 +++++--
.../operator/schema/SchemaFetchScanOperator.java | 10 +-
.../operator/schema/SchemaQueryMergeOperator.java | 7 +-
.../operator/schema/SchemaQueryScanOperator.java | 91 ++++++--
.../operator/schema/SchemaTsBlockUtil.java | 4 +
.../operator/schema/source/DeviceSchemaSource.java | 3 +-
.../operator/schema/source/ISchemaSource.java | 6 +-
.../schema/source/LogicalViewSchemaSource.java | 25 +--
.../operator/schema/source/NodeSchemaSource.java | 3 +-
.../schema/source/PathsUsingTemplateSource.java | 14 +-
.../schema/source/SchemaSourceFactory.java | 2 +-
.../schema/source/TimeSeriesSchemaSource.java | 5 +-
.../plan/planner/OperatorTreeGenerator.java | 6 +-
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 12 +-
.../schemaengine/metric/ISchemaEngineMetric.java | 1 +
.../schemaengine/metric/ISchemaRegionMetric.java | 1 +
.../metric/SchemaEngineCachedMetric.java | 1 +
.../schemaengine/metric/SchemaEngineMemMetric.java | 7 +-
.../schemaengine/metric/SchemaMetricManager.java | 25 +--
.../metric/SchemaRegionCachedMetric.java | 1 +
.../schemaengine/metric/SchemaRegionMemMetric.java | 1 +
.../schemaengine/schemaregion/ISchemaRegion.java | 4 -
.../schemaregion/logfile/BufferedSerializer.java | 2 +-
.../schemaregion/logfile/IDeserializer.java | 2 +-
.../schemaregion/logfile/ISerializer.java | 2 +-
.../schemaregion/logfile/MLogDescription.java | 1 +
.../logfile/MLogDescriptionReader.java | 11 +-
.../logfile/MLogDescriptionWriter.java | 20 +-
.../schemaregion/logfile/SchemaLogReader.java | 28 ++-
.../schemaregion/logfile/SchemaLogWriter.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 17 ++
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 16 ++
.../read/resp/reader/ISchemaReader.java | 44 +++-
.../impl/SchemaReaderLimitOffsetWrapper.java | 55 ++++-
.../reader/impl/TimeseriesReaderWithViewFetch.java | 145 +++++++++----
.../schemaengine/schemaregion/tag/TagLogFile.java | 15 +-
.../schemaengine/schemaregion/tag/TagManager.java | 81 ++++---
.../template/ClusterTemplateManager.java | 37 ++--
.../db/schemaengine/template/ITemplateManager.java | 19 +-
.../iotdb/db/schemaengine/template/Template.java | 15 +-
.../template/TemplateInternalRPCUtil.java | 4 +-
.../template/alter/TemplateAlterOperationUtil.java | 6 +-
.../template/alter/TemplateExtendInfo.java | 27 +--
.../iotdb/db/storageengine/StorageEngine.java | 10 -
.../db/storageengine/buffer/BloomFilterCache.java | 15 +-
.../storageengine/buffer/CacheHitRatioMonitor.java | 3 +-
.../iotdb/db/storageengine/buffer/ChunkCache.java | 4 +-
.../buffer/TimeSeriesMetadataCache.java | 3 +-
.../dataregion/compaction/settle/SettleLog.java | 6 +-
.../compaction/settle/SettleRequestHandler.java | 11 +-
.../dataregion/compaction/settle/SettleTask.java | 6 +-
.../dataregion/flush/FlushListener.java | 1 +
.../dataregion/flush/FlushManager.java | 4 +-
.../dataregion/flush/FlushManagerMetrics.java | 10 +-
.../dataregion/flush/MemTableFlushTask.java | 4 +-
.../flush/pool/FlushSubTaskPoolManager.java | 1 +
.../flush/pool/FlushTaskPoolManager.java | 1 +
.../dataregion/memtable/AbstractMemTable.java | 27 +--
.../memtable/AlignedWritableMemChunk.java | 11 +-
.../memtable/AlignedWritableMemChunkGroup.java | 1 +
.../dataregion/memtable/IDeviceID.java | 4 +-
.../dataregion/memtable/PlainDeviceID.java | 2 +-
.../dataregion/memtable/WritableMemChunk.java | 2 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 1 +
.../generator/SimpleFileVersionController.java | 3 +-
.../storageengine/dataregion/wal/WALManager.java | 23 +-
.../allocation/AbstractNodeAllocationStrategy.java | 3 +-
.../dataregion/wal/allocation/ElasticStrategy.java | 14 +-
.../wal/allocation/FirstCreateStrategy.java | 26 +--
.../wal/allocation/NodeAllocationStrategy.java | 9 +-
.../wal/allocation/RoundRobinStrategy.java | 14 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 22 +-
.../dataregion/wal/buffer/IWALBuffer.java | 21 +-
.../dataregion/wal/buffer/IWALByteBufferView.java | 1 +
.../dataregion/wal/buffer/WALBuffer.java | 38 ++--
.../dataregion/wal/buffer/WALEntry.java | 26 +--
.../dataregion/wal/buffer/WALEntryType.java | 17 +-
.../dataregion/wal/buffer/WALEntryValue.java | 1 +
.../dataregion/wal/buffer/WALInfoEntry.java | 51 ++++-
.../dataregion/wal/buffer/WALSignalEntry.java | 3 +-
.../dataregion/wal/checkpoint/Checkpoint.java | 12 +-
.../wal/checkpoint/CheckpointManager.java | 44 ++--
.../dataregion/wal/checkpoint/CheckpointType.java | 9 +-
.../dataregion/wal/checkpoint/MemTableInfo.java | 22 +-
.../wal/exception/MemTablePinException.java | 1 +
.../dataregion/wal/exception/WALException.java | 1 +
.../wal/exception/WALNodeClosedException.java | 1 +
.../dataregion/wal/exception/WALPipeException.java | 1 +
.../wal/exception/WALRecoverException.java | 1 +
.../dataregion/wal/io/CheckpointReader.java | 1 +
.../dataregion/wal/io/CheckpointWriter.java | 1 +
.../dataregion/wal/io/ILogWriter.java | 3 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 1 +
.../dataregion/wal/io/WALByteBufReader.java | 9 +-
.../dataregion/wal/io/WALMetaData.java | 8 +-
.../storageengine/dataregion/wal/io/WALReader.java | 16 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 10 +-
.../dataregion/wal/node/IWALNode.java | 9 +-
.../dataregion/wal/node/WALFakeNode.java | 14 +-
.../storageengine/dataregion/wal/node/WALNode.java | 69 +++---
.../wal/recover/CheckpointRecoverUtils.java | 5 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 8 +-
.../dataregion/wal/recover/WALRecoverManager.java | 9 +-
.../dataregion/wal/recover/WALRecoverWriter.java | 1 +
.../file/AbstractTsFileRecoverPerformer.java | 10 +-
.../recover/file/SealedTsFileRecoverPerformer.java | 6 +-
.../wal/recover/file/TsFilePlanRedoer.java | 12 +-
.../file/UnsealedTsFileRecoverPerformer.java | 23 +-
.../dataregion/wal/utils/CheckpointFileUtils.java | 15 +-
.../dataregion/wal/utils/WALEntryHandler.java | 15 +-
.../dataregion/wal/utils/WALEntryPosition.java | 27 ++-
.../dataregion/wal/utils/WALFileStatus.java | 5 +-
.../dataregion/wal/utils/WALFileUtils.java | 17 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 9 +-
.../dataregion/wal/utils/WALMode.java | 17 +-
.../dataregion/wal/utils/WALWriteUtils.java | 21 +-
.../wal/utils/listener/AbstractResultListener.java | 5 +-
.../wal/utils/listener/WALFlushListener.java | 1 +
.../wal/utils/listener/WALRecoverListener.java | 3 +-
.../iotdb/db/storageengine/upgrade/UpgradeLog.java | 7 +-
.../db/storageengine/upgrade/UpgradeTask.java | 44 ++--
.../java/org/apache/iotdb/db/tools/WalChecker.java | 3 +-
.../utils/datastructure/PatternTreeMapFactory.java | 6 +
.../execution/operator/OperatorMemoryTest.java | 6 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 1 -
.../operator/schema/SchemaOperatorTestUtil.java | 12 +-
.../resources/conf/iotdb-common.properties | 8 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 23 +-
.../iotdb/commons/conf/CommonDescriptor.java | 11 +-
...xception.java => SchemaExecutionException.java} | 12 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 13 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 2 +-
.../thrift/src/main/thrift/datanode.thrift | 13 ++
.../org/apache/iotdb/library/anomaly/UDTFIQR.java | 21 +-
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 30 +--
.../org/apache/iotdb/library/anomaly/UDTFLOF.java | 18 +-
.../apache/iotdb/library/anomaly/UDTFOutlier.java | 14 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 7 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 7 +-
.../iotdb/library/anomaly/util/MissDetector.java | 8 +-
.../library/anomaly/util/StreamMissDetector.java | 24 ++-
.../iotdb/library/anomaly/util/WindowDetect.java | 6 +-
.../org/apache/iotdb/library/dlearn/UDTFAR.java | 19 +-
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 20 +-
.../apache/iotdb/library/dmatch/UDAFPearson.java | 36 ++--
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 7 +-
.../library/dmatch/util/CrossCorrelation.java | 13 +-
.../iotdb/library/dprofile/UDAFIntegral.java | 5 +-
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 2 +-
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 2 +-
.../apache/iotdb/library/dprofile/UDAFMedian.java | 2 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 14 +-
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 28 +--
.../iotdb/library/dprofile/UDAFQuantile.java | 19 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 36 ++--
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 5 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 12 ++
.../iotdb/library/dprofile/UDTFHistogram.java | 1 +
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 20 +-
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 6 +-
.../apache/iotdb/library/dprofile/UDTFPACF.java | 1 +
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 1 +
.../iotdb/library/dprofile/UDTFResample.java | 12 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 19 +-
.../apache/iotdb/library/dprofile/UDTFSegment.java | 34 +--
.../apache/iotdb/library/dprofile/UDTFSpline.java | 2 +-
.../apache/iotdb/library/dprofile/UDTFZScore.java | 20 +-
.../library/dprofile/util/CrossCorrelation.java | 14 +-
.../dprofile/util/ExactOrderStatistics.java | 139 ++++++------
.../iotdb/library/dprofile/util/GKArray.java | 22 +-
.../library/dprofile/util/HeapLongKLLSketch.java | 237 ++++++++++-----------
.../dprofile/util/KLLSketchForQuantile.java | 155 +++++++-------
.../iotdb/library/dprofile/util/MADSketch.java | 157 +++++++-------
.../apache/iotdb/library/dprofile/util/Mad.java | 9 +-
.../iotdb/library/dprofile/util/MaxSelector.java | 3 +-
.../iotdb/library/dprofile/util/Resampler.java | 17 +-
.../iotdb/library/dprofile/util/Segment.java | 141 ++++++------
.../iotdb/library/dprofile/util/YuleWalker.java | 11 +-
.../iotdb/library/dquality/UDTFCompleteness.java | 2 +-
.../iotdb/library/dquality/UDTFConsistency.java | 2 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 2 +-
.../iotdb/library/dquality/UDTFValidity.java | 2 +-
.../library/dquality/util/TimeSeriesQuality.java | 21 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 5 +-
.../iotdb/library/drepair/UDTFValueFill.java | 6 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 3 +-
.../apache/iotdb/library/drepair/util/ARFill.java | 34 ++-
.../iotdb/library/drepair/util/LikelihoodFill.java | 15 +-
.../iotdb/library/drepair/util/LinearFill.java | 1 +
.../iotdb/library/drepair/util/LsGreedy.java | 12 +-
.../apache/iotdb/library/drepair/util/MAFill.java | 21 +-
.../iotdb/library/drepair/util/MeanFill.java | 1 +
.../iotdb/library/drepair/util/PreviousFill.java | 1 +
.../apache/iotdb/library/drepair/util/Screen.java | 4 +-
.../iotdb/library/drepair/util/ScreenFill.java | 30 +--
.../library/drepair/util/TimestampInterval.java | 13 +-
.../library/drepair/util/TimestampRepair.java | 56 ++---
.../iotdb/library/drepair/util/ValueFill.java | 21 +-
.../iotdb/library/drepair/util/ValueRepair.java | 11 +-
.../apache/iotdb/library/frequency/UDTFDWT.java | 1 +
.../apache/iotdb/library/frequency/UDTFDeconv.java | 18 +-
.../apache/iotdb/library/frequency/UDTFFFT.java | 7 +-
.../iotdb/library/frequency/UDTFHighPass.java | 8 +-
.../apache/iotdb/library/frequency/UDTFIDWT.java | 1 +
.../apache/iotdb/library/frequency/UDTFIFFT.java | 11 +-
.../iotdb/library/frequency/UDTFLowPass.java | 8 +-
.../iotdb/library/frequency/util/DWTUtil.java | 12 +-
.../iotdb/library/frequency/util/FFTUtil.java | 12 +-
.../library/series/UDTFConsecutiveWindows.java | 4 +-
.../iotdb/library/series/util/ConsecutiveUtil.java | 18 +-
.../iotdb/library/util/BooleanCircularQueue.java | 31 +--
.../apache/iotdb/library/util/CircularQueue.java | 29 +--
.../iotdb/library/util/DoubleCircularQueue.java | 31 +--
.../iotdb/library/util/LinearRegression.java | 15 +-
.../iotdb/library/util/LongCircularQueue.java | 35 +--
.../iotdb/library/util/NoNumberException.java | 1 +
.../java/org/apache/iotdb/library/util/Util.java | 63 +++---
325 files changed, 3008 insertions(+), 2140 deletions(-)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{AsyncTSStatusRPCHandler.java
=> PipeHeartbeatRPCHandler.java} (61%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/runtime/PipeHeartbeatScheduler.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/UnSupportedDataTypeException.java
=>
datanode/src/main/java/org/apache/iotdb/db/exception/metadata/SchemaExecutionException.java}
(76%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/SeriesNumberOverflowException.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/{UnSupportedDataTypeException.java
=> SchemaExecutionException.java} (76%)
