org.apache.hadoop.hive.hbase

Class AbstractHBaseKeyPredicateDecomposer

java.lang.Object

org.apache.hadoop.hive.hbase.AbstractHBaseKeyPredicateDecomposer

public abstract class AbstractHBaseKeyPredicateDecomposer
extends Object

Simple abstract class to help with creation of a HiveStoragePredicateHandler.DecomposedPredicate. In order to create one, consumers should extend this class and override the "getScanRange" method to define the start/stop keys and/or filters on their hbase scans

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Constructor and Description
AbstractHBaseKeyPredicateDecomposer()

Method Summary

Methods

Modifier and Type	Method and Description
HiveStoragePredicateHandler.DecomposedPredicate	decomposePredicate(String keyColName, ExprNodeDesc predicate)
protected IndexPredicateAnalyzer.FieldValidator	getFieldValidator() Get an optional validator.
protected abstract HBaseScanRange	getScanRange(List<IndexSearchCondition> searchConditions) Get the scan range that specifies the start/stop keys and/or filters to be applied onto the hbase scan

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

Constructor Detail

AbstractHBaseKeyPredicateDecomposer

public AbstractHBaseKeyPredicateDecomposer()

Method Detail

decomposePredicate

public HiveStoragePredicateHandler.DecomposedPredicate decomposePredicate(String keyColName,
                                                                 ExprNodeDesc predicate)

getScanRange

protected abstract HBaseScanRange getScanRange(List<IndexSearchCondition> searchConditions)
                                        throws Exception

Get the scan range that specifies the start/stop keys and/or filters to be applied onto the hbase scan

Throws:

Exception

getFieldValidator

protected IndexPredicateAnalyzer.FieldValidator getFieldValidator()

Get an optional validator. A validator can be used to optinally filter out the predicates which need not be decomposed. By default this method returns null which means that all predicates are pushed but consumers can choose to override this to provide a custom validator as well.