public class CompositeHBaseKeyFactory<T extends HBaseCompositeKey> extends DefaultHBaseKeyFactory
HiveStoragePredicateHandler.DecomposedPredicate
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
serdeParams, serializer
hbaseParams, keyMapping, properties
Constructor and Description |
---|
CompositeHBaseKeyFactory(Class<T> keyClass) |
Modifier and Type | Method and Description |
---|---|
void |
configureJobConf(TableDesc tableDesc,
org.apache.hadoop.mapred.JobConf jobConf)
configure jobConf for this factory
|
T |
createKey(ObjectInspector inspector)
create custom object for hbase key
|
createKeyObjectInspector, init, serializeKey
decomposePredicate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decomposePredicate
public void configureJobConf(TableDesc tableDesc, org.apache.hadoop.mapred.JobConf jobConf) throws IOException
HBaseKeyFactory
configureJobConf
in interface HBaseKeyFactory
configureJobConf
in class AbstractHBaseKeyFactory
IOException
public T createKey(ObjectInspector inspector) throws SerDeException
HBaseKeyFactory
createKey
in interface HBaseKeyFactory
createKey
in class DefaultHBaseKeyFactory
inspector
- OI create by HBaseKeyFactory.createKeyObjectInspector(org.apache.hadoop.hive.serde2.typeinfo.TypeInfo)
SerDeException
Copyright © 2017 The Apache Software Foundation. All rights reserved.