diff --git a/hbase-handler/src/java/org/apache/hadoop/hive/hbase/struct/DefaultHBaseValueFactory.java b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/struct/DefaultHBaseValueFactory.java index f7a425d..e60b844 100644 --- a/hbase-handler/src/java/org/apache/hadoop/hive/hbase/struct/DefaultHBaseValueFactory.java +++ b/hbase-handler/src/java/org/apache/hadoop/hive/hbase/struct/DefaultHBaseValueFactory.java @@ -35,7 +35,7 @@ /** * Default implementation of the {@link HBaseValueFactory} * */ -public class DefaultHBaseValueFactory implements HBaseValueFactory{ +public class DefaultHBaseValueFactory implements HBaseValueFactory { protected LazySimpleSerDe.SerDeParameters serdeParams; protected ColumnMappings columnMappings; @@ -49,32 +49,32 @@ public DefaultHBaseValueFactory(int fieldID) { this.fieldID = fieldID; } - @Override + @Override public void init(HBaseSerDeParameters hbaseParams, Configuration conf, Properties properties) - throws SerDeException { + throws SerDeException { this.hbaseParams = hbaseParams; this.serdeParams = hbaseParams.getSerdeParams(); this.columnMappings = hbaseParams.getColumnMappings(); this.properties = properties; this.conf = conf; - } + } - @Override - public ObjectInspector createValueObjectInspector(TypeInfo type) - throws SerDeException { + @Override + public ObjectInspector createValueObjectInspector(TypeInfo type) + throws SerDeException { return LazyFactory.createLazyObjectInspector(type, serdeParams.getSeparators(), 1, serdeParams.getNullSequence(), serdeParams.isEscaped(), serdeParams.getEscapeChar()); - } + } @Override public LazyObjectBase createValueObject(ObjectInspector inspector) throws SerDeException { return HBaseSerDeHelper.createLazyField(columnMappings.getColumnsMapping(), fieldID, inspector); } - @Override - public byte[] serializeValue(Object object, StructField field) - throws IOException { + @Override + public byte[] serializeValue(Object object, StructField field) + throws IOException { // TODO Add support for serialization of values here - return null; - } -} \ No newline at end of file + return null; + } +}