diff --git hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java index 255ffa2..599c2f0 100644 --- hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java +++ hbase-handler/src/java/org/apache/hadoop/hive/hbase/HBaseStorageHandler.java @@ -20,7 +20,6 @@ import java.io.IOException; import java.util.ArrayList; -import java.util.Arrays; import java.util.HashSet; import java.util.LinkedHashSet; import java.util.List; @@ -411,11 +410,6 @@ public static DecomposedPredicate decomposePredicate( JobConf jobConf, HBaseSerDe hBaseSerDe, ExprNodeDesc predicate) { - String columnNameProperty = jobConf.get( - org.apache.hadoop.hive.serde.serdeConstants.LIST_COLUMNS); - List columnNames = - Arrays.asList(columnNameProperty.split(",")); - ColumnMapping keyMapping = hBaseSerDe.getHBaseSerdeParam().getKeyColumnMapping(); IndexPredicateAnalyzer analyzer = HiveHBaseTableInputFormat.newIndexPredicateAnalyzer( keyMapping.columnName, keyMapping.columnType, keyMapping.binaryStorage.get(0));