Skip to content

Subscription: support table-model column-filter for topics#17936

Open
VGalaxies wants to merge 16 commits into
masterfrom
feature/subscription-column-filter
Open

Subscription: support table-model column-filter for topics#17936
VGalaxies wants to merge 16 commits into
masterfrom
feature/subscription-column-filter

spotless

bcf6671
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jul 1, 2026 in 2m 55s

Quality Gate failed

Failed conditions
B Reliability Rating on New Code (required ≥ A)

See analysis details on SonarQube Cloud

Catch issues before they fail your Quality Gate with our IDE extension SonarQube for IDE

Annotations

Check warning on line 178 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor the code in order to not assign to this loop counter from within the loop body.

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

Check warning on line 146 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor the code in order to not assign to this loop counter from within the loop body.

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

Check warning on line 76 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a thread-safe type; adding "volatile" is not enough to make this field thread-safe.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7-TtPhYdh0ur_Z_Ov6&open=AZ7-TtPhYdh0ur_Z_Ov6&pullRequest=17936

Check warning on line 1230 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'block' child has incorrect indentation level 12, expected level should be 10.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g8lzat-rTvK-hye&open=AZ688g8lzat-rTvK-hye&pullRequest=17936

Check warning on line 66 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterEvaluator.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a primitive boolean expression here.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g6yzat-rTvK-hyS&open=AZ688g6yzat-rTvK-hyS&pullRequest=17936

Check warning on line 404 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/subscription/SubscriptionInfo.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=AZ74Xf_GWYpOdl3gWQoF&open=AZ74Xf_GWYpOdl3gWQoF&pullRequest=17936

Check warning on line 822 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.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 67 to 64, Complexity from 17 to 14, Nesting Level from 3 to 2, Number of Variables from 17 to 6.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g2dzat-rTvK-hyM&open=AZ688g2dzat-rTvK-hyM&pullRequest=17936

Check warning on line 74 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterEvaluator.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a primitive boolean expression here.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g6zzat-rTvK-hyT&open=AZ688g6zzat-rTvK-hyT&pullRequest=17936

Check warning on line 1229 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'block' child has incorrect indentation level 12, expected level should be 10.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g8lzat-rTvK-hyd&open=AZ688g8lzat-rTvK-hyd&pullRequest=17936

Check failure on line 565 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusLogToTabletConverter.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=AZ688g21zat-rTvK-hyO&open=AZ688g21zat-rTvK-hyO&pullRequest=17936

Check warning on line 1942 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 106).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7-TtSUYdh0ur_Z_Ov_&open=AZ7-TtSUYdh0ur_Z_Ov_&pullRequest=17936

Check warning on line 292 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 123).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7-TtPhYdh0ur_Z_Ov8&open=AZ7-TtPhYdh0ur_Z_Ov8&pullRequest=17936

Check warning on line 86 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TreeViewTabletProjector.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=AZ7-TtRFYdh0ur_Z_Ov9&open=AZ7-TtRFYdh0ur_Z_Ov9&pullRequest=17936

Check warning on line 110 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterBinder.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Merge the previous cases into this one using comma-separated label.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g6qzat-rTvK-hyR&open=AZ688g6qzat-rTvK-hyR&pullRequest=17936

Check failure on line 66 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TreeViewTabletProjector.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7-TtRFYdh0ur_Z_Ov-&open=AZ7-TtRFYdh0ur_Z_Ov-&pullRequest=17936

Check warning on line 166 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Return an empty collection instead of null.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7-TtPhYdh0ur_Z_Ov7&open=AZ7-TtPhYdh0ur_Z_Ov7&pullRequest=17936

Check warning on line 314 in iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/config/TopicConfig.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this lambda with method reference 'expectedKey::equalsIgnoreCase'.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g-Azat-rTvK-hyi&open=AZ688g-Azat-rTvK-hyi&pullRequest=17936

Check warning on line 66 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove duplicates in this character class.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g7Dzat-rTvK-hyZ&open=AZ688g7Dzat-rTvK-hyZ&pullRequest=17936

Check warning on line 1979 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Method has 10 parameters, which is greater than 7 authorized.

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

Check warning on line 104 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeTabletEventTsFileBatch.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=AZ688gvxzat-rTvK-hyL&open=AZ688gvxzat-rTvK-hyL&pullRequest=17936

Check warning on line 91 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterBinder.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=AZ688g6qzat-rTvK-hyQ&open=AZ688g6qzat-rTvK-hyQ&pullRequest=17936

Check warning on line 151 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor the code in order to not assign to this loop counter from within the loop body.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g7Dzat-rTvK-hyW&open=AZ688g7Dzat-rTvK-hyW&pullRequest=17936

Check failure on line 1979 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusPrefetchingQueue.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check failure on line 131 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/ColumnFilterParser.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 1151 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.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 94 to 64, Complexity from 15 to 14, Nesting Level from 4 to 2, Number of Variables from 22 to 6.

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g8lzat-rTvK-hyc&open=AZ688g8lzat-rTvK-hyc&pullRequest=17936