Skip to content

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

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

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

Update ConsensusSubscriptionSetupHandler.java

32a986e
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jun 26, 2026 in 3m 8s

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 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 62 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

Use concise character class syntax '\\w' instead of '[A-Za-z_0-9]'. 

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

Check warning on line 153 in iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/SubscriptionPollResponse.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the unnecessary boolean literal. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g9jzat-rTvK-hyh&open=AZ688g9jzat-rTvK-hyh&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 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 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 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 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 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 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 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 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 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 1181 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 90 to 64, Complexity from 20 to 14, Nesting Level from 4 to 2, Number of Variables from 10 to 6. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g2dzat-rTvK-hyN&open=AZ688g2dzat-rTvK-hyN&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 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 1870 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 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

Use concise character class syntax '\\w' instead of '[A-Za-z_0-9]'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g7Dzat-rTvK-hyb&open=AZ688g7Dzat-rTvK-hyb&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 41 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/columnfilter/TabletColumnPruner.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 82 to 64, Complexity from 25 to 14, Nesting Level from 3 to 2, Number of Variables from 23 to 6. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g66zat-rTvK-hyV&open=AZ688g66zat-rTvK-hyV&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 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 warning on line 64 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

Use concise character class syntax '\\w' instead of '[A-Za-z_0-9]'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ688g7Dzat-rTvK-hyY&open=AZ688g7Dzat-rTvK-hyY&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
View more details on SonarQubeCloud