diff --git hbase-handler/src/java/org/apache/hadoop/hive/hbase/ColumnMappings.java hbase-handler/src/java/org/apache/hadoop/hive/hbase/ColumnMappings.java index 9cae5d3..60dbf65 100644 --- hbase-handler/src/java/org/apache/hadoop/hive/hbase/ColumnMappings.java +++ hbase-handler/src/java/org/apache/hadoop/hive/hbase/ColumnMappings.java @@ -285,8 +285,11 @@ public int getKeyIndex() { return columnsMapping; } + /** + * Represents a mapping from a single Hive column to an HBase column qualifier, column family or row key. + */ // todo use final fields - static class ColumnMapping { + public static class ColumnMapping { ColumnMapping() { binaryStorage = new ArrayList(2); @@ -305,8 +308,54 @@ public int getKeyIndex() { String qualifierPrefix; byte[] qualifierPrefixBytes; + public String getColumnName() { + return columnName; + } + + public TypeInfo getColumnType() { + return columnType; + } + + public String getFamilyName() { + return familyName; + } + + public String getQualifierName() { + return qualifierName; + } + + public byte[] getFamilyNameBytes() { + return familyNameBytes; + } + + public byte[] getQualifierNameBytes() { + return qualifierNameBytes; + } + + public List getBinaryStorage() { + return binaryStorage; + } + + public boolean isHbaseRowKey() { + return hbaseRowKey; + } + + public String getMappingSpec() { + return mappingSpec; + } + + public String getQualifierPrefix() { + return qualifierPrefix; + } + + public byte[] getQualifierPrefixBytes() { + return qualifierPrefixBytes; + } + public boolean isCategory(ObjectInspector.Category category) { return columnType.getCategory() == category; } + + } }