Skip to content

Pipe: order historical TsFiles by query priority#18088

Open
Caideyipi wants to merge 4 commits into
masterfrom
pipe-history-tsfile-flush-order
Open

Pipe: order historical TsFiles by query priority#18088
Caideyipi wants to merge 4 commits into
masterfrom
pipe-history-tsfile-flush-order

Pipe: report time-partition historical progress

dd886fa
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis succeeded Jul 7, 2026 in 2m 53s

Quality Gate passed

Issues
16 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

Annotations

Check warning on line 642 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Reduce the total number of break and continue statements in this loop to use at most one. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOj&open=AZ88TAvpj_ZpjqL4MfOj&pullRequest=18088

Check failure on line 1259 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 16 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ8gv7ZwXgCgWw53Sru2&open=AZ8gv7ZwXgCgWw53Sru2&pullRequest=18088

Check warning on line 137 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/TimePartitionProgressIndex.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof HybridProgressIndex hybridprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAi-j_ZpjqL4MfOi&open=AZ88TAi-j_ZpjqL4MfOi&pullRequest=18088

Check warning on line 501 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof HybridProgressIndex hybridprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOm&open=AZ88TAvpj_ZpjqL4MfOm&pullRequest=18088

Check warning on line 981 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TimePartitionProgressIndex timepartitionprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOs&open=AZ88TAvpj_ZpjqL4MfOs&pullRequest=18088

Check warning on line 413 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof PipeTsFileInsertionEvent pipetsfileinsertionevent' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ8gv7UHXgCgWw53Sruy&open=AZ8gv7UHXgCgWw53Sruy&pullRequest=18088

Check warning on line 976 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof HybridProgressIndex hybridprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOr&open=AZ88TAvpj_ZpjqL4MfOr&pullRequest=18088

Check warning on line 552 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 103 to 64, Complexity from 21 to 14, Nesting Level from 5 to 2, Number of Variables from 13 to 6. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ8gv7ZSXgCgWw53Sruz&open=AZ8gv7ZSXgCgWw53Sruz&pullRequest=18088

Check warning on line 490 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TimePartitionProgressIndex timepartitionprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOl&open=AZ88TAvpj_ZpjqL4MfOl&pullRequest=18088

Check warning on line 946 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof StateProgressIndex stateprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOo&open=AZ88TAvpj_ZpjqL4MfOo&pullRequest=18088

Check warning on line 698 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TsFileResource tsfileresource' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ8gv7ZwXgCgWw53Sru0&open=AZ8gv7ZwXgCgWw53Sru0&pullRequest=18088

Check warning on line 477 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof StateProgressIndex stateProgressIndex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOk&open=AZ88TAvpj_ZpjqL4MfOk&pullRequest=18088

Check warning on line 972 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TimePartitionProgressIndex timepartitionprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOq&open=AZ88TAvpj_ZpjqL4MfOq&pullRequest=18088

Check failure on line 1108 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 32 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ8gv7ZwXgCgWw53Sru1&open=AZ8gv7ZwXgCgWw53Sru1&pullRequest=18088

Check warning on line 948 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested ternary operation into an independent statement. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOp&open=AZ88TAvpj_ZpjqL4MfOp&pullRequest=18088

Check warning on line 909 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TimeWindowStateProgressIndex timewindowstateprogressindex' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ88TAvpj_ZpjqL4MfOn&open=AZ88TAvpj_ZpjqL4MfOn&pullRequest=18088
View more details on SonarQubeCloud