From 370df744c03c40995e8d1f92524de8802934289e Mon Sep 17 00:00:00 2001 From: shaofengshi Date: Tue, 6 Jan 2015 22:58:33 +0800 Subject: [PATCH] small update in filter --- .../com/kylinolap/job/hadoop/cardinality/HiveColumnCardinalityJob.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/job/src/main/java/com/kylinolap/job/hadoop/cardinality/HiveColumnCardinalityJob.java b/job/src/main/java/com/kylinolap/job/hadoop/cardinality/HiveColumnCardinalityJob.java index ba6eba0..d6f0e5a 100644 --- a/job/src/main/java/com/kylinolap/job/hadoop/cardinality/HiveColumnCardinalityJob.java +++ b/job/src/main/java/com/kylinolap/job/hadoop/cardinality/HiveColumnCardinalityJob.java @@ -138,7 +138,7 @@ public int run(String[] args) throws Exception { // Mapper this.table = getOptionValue(OPTION_TABLE); System.out.println("Going to start HiveColumnCardinalityJob on table '" + table + "'"); - String filter = "\"dt\"=\"20150101\" and \"hour\"=\"00\""; + String filter = "dt=\"20150101\" and hour=\"00\""; HCatInputFormat.setInput(job, "default", table, filter);