diff options
author | Steven Phillips <steven@dremio.com> | 2016-02-04 17:43:17 -0800 |
---|---|---|
committer | Steven Phillips <steven@dremio.com> | 2016-02-16 11:58:48 -0800 |
commit | 9a3a5c4ff670a50a49f61f97dd838da59a12f976 (patch) | |
tree | a358c895b74b8553c79befa5bce50940c631b1c3 /contrib/storage-hbase/src | |
parent | 0a2518d7cf01a92a27a82e29edac5424bedf31d5 (diff) |
DRILL-4382: Remove dependency on drill-logical from vector package
Diffstat (limited to 'contrib/storage-hbase/src')
-rw-r--r-- | contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java index d093522b8..0af00098f 100644 --- a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java +++ b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseRecordReader.java @@ -145,7 +145,7 @@ public class HBaseRecordReader extends AbstractRecordReader implements DrillHBas // when creating reader (order of first appearance in query). for (SchemaPath column : getColumns()) { if (column.equals(ROW_KEY_PATH)) { - MaterializedField field = MaterializedField.create(column, ROW_KEY_TYPE); + MaterializedField field = MaterializedField.create(column.getAsNamePart().getName(), ROW_KEY_TYPE); rowKeyVector = outputMutator.addField(field, VarBinaryVector.class); } else { getOrCreateFamilyVector(column.getRootSegment().getPath(), false); @@ -246,7 +246,7 @@ public class HBaseRecordReader extends AbstractRecordReader implements DrillHBas MapVector v = familyVectorMap.get(familyName); if(v == null) { SchemaPath column = SchemaPath.getSimplePath(familyName); - MaterializedField field = MaterializedField.create(column, COLUMN_FAMILY_TYPE); + MaterializedField field = MaterializedField.create(column.getAsNamePart().getName(), COLUMN_FAMILY_TYPE); v = outputMutator.addField(field, MapVector.class); if (allocateOnCreate) { v.allocateNew(); |