You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2019/06/13 02:27:50 UTC
[kylin] 02/02: KYLIN-4015 change uhc path filter .dci to
FactDistinctColumnsReducer.DIMENSION_COL_INFO_FILE_POSTFIX
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git
commit f19f16aad334fd65f9946dd51d369497a15cb9e4
Author: shqmh <sh...@126.com>
AuthorDate: Wed Jun 12 20:22:10 2019 +0800
KYLIN-4015 change uhc path filter .dci to FactDistinctColumnsReducer.DIMENSION_COL_INFO_FILE_POSTFIX
---
.../org/apache/kylin/engine/mr/steps/filter/UHCDictPathFilter.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/filter/UHCDictPathFilter.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/filter/UHCDictPathFilter.java
index 44a837b..4c5b84d 100644
--- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/filter/UHCDictPathFilter.java
+++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/steps/filter/UHCDictPathFilter.java
@@ -20,6 +20,7 @@ package org.apache.kylin.engine.mr.steps.filter;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PathFilter;
+import org.apache.kylin.engine.mr.steps.FactDistinctColumnsReducer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,16 +31,14 @@ import java.util.regex.Pattern;
public class UHCDictPathFilter implements PathFilter {
private static final Logger logger = LoggerFactory.getLogger(UHCDictPathFilter.class);
- private static final String DCIFILE_POSTFIX = ".dci";
-
@Override
public boolean accept(Path path) {
- Pattern pattern = Pattern.compile(DCIFILE_POSTFIX);
+ Pattern pattern = Pattern.compile(FactDistinctColumnsReducer.DIMENSION_COL_INFO_FILE_POSTFIX);
Matcher matcher = pattern.matcher(path.getName().toLowerCase(Locale.ROOT));
if (matcher.find()) {
- logger.info("filter file: " + path.getName());
+ logger.info("filter dict file: " + path.getName());
return false;
}