org.apache.hadoop.hive.hbase

Class AbstractHBaseKeyFactory

java.lang.Object

org.apache.hadoop.hive.hbase.AbstractHBaseKeyFactory

All Implemented Interfaces:

HBaseKeyFactory, HiveStoragePredicateHandler

Direct Known Subclasses:

DefaultHBaseKeyFactory

public abstract class AbstractHBaseKeyFactory
extends Object
implements HBaseKeyFactory

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.ql.metadata.HiveStoragePredicateHandler

HiveStoragePredicateHandler.DecomposedPredicate

Field Summary

Fields

Modifier and Type	Field and Description
protected HBaseSerDeParameters	hbaseParams
protected ColumnMappings.ColumnMapping	keyMapping
protected Properties	properties

Constructor Summary

Constructors

Constructor and Description
AbstractHBaseKeyFactory()

Method Summary

Methods

Modifier and Type	Method and Description
void	configureJobConf(TableDesc tableDesc, org.apache.hadoop.mapred.JobConf jobConf) configure jobConf for this factory
HiveStoragePredicateHandler.DecomposedPredicate	decomposePredicate(org.apache.hadoop.mapred.JobConf jobConf, Deserializer deserializer, ExprNodeDesc predicate) Gives the storage handler a chance to decompose a predicate.
void	init(HBaseSerDeParameters hbaseParam, Properties properties) initialize factory with properties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hive.hbase.HBaseKeyFactory

createKey, createKeyObjectInspector, serializeKey

Field Detail

hbaseParams

protected HBaseSerDeParameters hbaseParams

keyMapping

protected ColumnMappings.ColumnMapping keyMapping

properties

protected Properties properties

Constructor Detail

AbstractHBaseKeyFactory

public AbstractHBaseKeyFactory()

Method Detail

init

public void init(HBaseSerDeParameters hbaseParam,
        Properties properties)
          throws SerDeException

Description copied from interface: HBaseKeyFactory

initialize factory with properties

Specified by:

init in interface HBaseKeyFactory

Throws:

SerDeException

configureJobConf

public void configureJobConf(TableDesc tableDesc,
                    org.apache.hadoop.mapred.JobConf jobConf)
                      throws IOException

Description copied from interface: HBaseKeyFactory

configure jobConf for this factory

Specified by:

configureJobConf in interface HBaseKeyFactory

Throws:

IOException

decomposePredicate

public HiveStoragePredicateHandler.DecomposedPredicate decomposePredicate(org.apache.hadoop.mapred.JobConf jobConf,
                                                                 Deserializer deserializer,
                                                                 ExprNodeDesc predicate)

Description copied from interface: HiveStoragePredicateHandler

Gives the storage handler a chance to decompose a predicate. The storage handler should analyze the predicate and return the portion of it which cannot be evaluated during table access. For example, if the original predicate is x = 2 AND upper(y)='YUM', the storage handler might be able to handle x = 2 but leave the "residual" upper(y)='YUM' for Hive to deal with. The breakdown need not be non-overlapping; for example, given the predicate x LIKE 'a%b', the storage handler might be able to evaluate the prefix search x LIKE 'a%', leaving x LIKE '%b' as the residual.

Specified by:

decomposePredicate in interface HiveStoragePredicateHandler

Parameters:

jobConf - contains a job configuration matching the one that will later be passed to getRecordReader and getSplits

deserializer - deserializer which will be used when fetching rows

predicate - predicate to be decomposed

Returns:

decomposed form of predicate, or null if no pushdown is possible at all