This is an automated email from the ASF dual-hosted git repository. wuweijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push: new 887bfdf99f0 Refactor MaskTable (#30568) 887bfdf99f0 is described below commit 887bfdf99f01b958bb6ece3ebcc1889eac5af92d Author: Liang Zhang <zhangli...@apache.org> AuthorDate: Wed Mar 20 21:46:48 2024 +0800 Refactor MaskTable (#30568) --- .../main/java/org/apache/shardingsphere/mask/rule/MaskTable.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java index 853fd9a1095..b2aa82d634e 100644 --- a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java +++ b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java @@ -24,6 +24,7 @@ import org.apache.shardingsphere.mask.spi.MaskAlgorithm; import java.util.Map; import java.util.Optional; +import java.util.stream.Collectors; /** * Mask table. @@ -33,10 +34,8 @@ public final class MaskTable { private final Map<String, MaskColumn> columns; public MaskTable(final MaskTableRuleConfiguration config, final Map<String, MaskAlgorithm<?, ?>> maskAlgorithms) { - columns = new CaseInsensitiveMap<>(); - for (MaskColumnRuleConfiguration each : config.getColumns()) { - columns.put(each.getLogicColumn(), new MaskColumn(each.getLogicColumn(), maskAlgorithms.get(each.getMaskAlgorithm()))); - } + columns = config.getColumns().stream().collect(Collectors.toMap(MaskColumnRuleConfiguration::getLogicColumn, + each -> new MaskColumn(each.getLogicColumn(), maskAlgorithms.get(each.getMaskAlgorithm())), (oldValue, currentValue) -> oldValue, CaseInsensitiveMap::new)); } /**