org.apache.hadoop.hive.accumulo.predicate

Class AccumuloRangeGenerator

java.lang.Object

org.apache.hadoop.hive.accumulo.predicate.AccumuloRangeGenerator

All Implemented Interfaces:

NodeProcessor

public class AccumuloRangeGenerator
extends Object
implements NodeProcessor

Constructor Summary

Constructors

Constructor and Description
AccumuloRangeGenerator(AccumuloPredicateHandler predicateHandler, HiveAccumuloRowIdColumnMapping rowIdMapping, String hiveRowIdColumnName)

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.hadoop.io.Text	getBinaryValue(ConstantObjectInspector objInspector) Attempts to construct the binary value from the given inspector.
protected org.apache.accumulo.core.data.Range	getColumnOpConstantRange(Class<? extends CompareOp> opClz, org.apache.hadoop.io.Text constText)
protected org.apache.accumulo.core.data.Range	getConstantOpColumnRange(Class<? extends CompareOp> opClz, org.apache.hadoop.io.Text constText)
protected org.apache.hadoop.io.Text	getUtf8Value(ConstantObjectInspector objInspector)
Object	process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx, Object... nodeOutputs) Generic process for all ops that don't have specific implementations.
protected Object	processAndOpNode(Node nd, Object[] nodeOutputs)
protected Object	processExpression(ExprNodeGenericFuncDesc func, Object[] nodeOutputs)
protected Object	processOrOpNode(Node nd, Object[] nodeOutputs)

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloRangeGenerator

public AccumuloRangeGenerator(AccumuloPredicateHandler predicateHandler,
                      HiveAccumuloRowIdColumnMapping rowIdMapping,
                      String hiveRowIdColumnName)

Method Detail

process

public Object process(Node nd,
             Stack<Node> stack,
             NodeProcessorCtx procCtx,
             Object... nodeOutputs)
               throws SemanticException

Description copied from interface: NodeProcessor

Generic process for all ops that don't have specific implementations.

Specified by:

process in interface NodeProcessor

Parameters:

nd - operator to process

procCtx - operator processor context

nodeOutputs - A variable argument list of outputs from other nodes in the walk

Returns:

Object to be returned by the process call

Throws:

SemanticException

processAndOpNode

protected Object processAndOpNode(Node nd,
                      Object[] nodeOutputs)

processOrOpNode

protected Object processOrOpNode(Node nd,
                     Object[] nodeOutputs)

processExpression

protected Object processExpression(ExprNodeGenericFuncDesc func,
                       Object[] nodeOutputs)
                            throws SemanticException

Throws:

SemanticException

getConstantOpColumnRange

protected org.apache.accumulo.core.data.Range getConstantOpColumnRange(Class<? extends CompareOp> opClz,
                                                           org.apache.hadoop.io.Text constText)

getColumnOpConstantRange

protected org.apache.accumulo.core.data.Range getColumnOpConstantRange(Class<? extends CompareOp> opClz,
                                                           org.apache.hadoop.io.Text constText)

getUtf8Value

protected org.apache.hadoop.io.Text getUtf8Value(ConstantObjectInspector objInspector)

getBinaryValue

protected org.apache.hadoop.io.Text getBinaryValue(ConstantObjectInspector objInspector)
                                            throws IOException

Attempts to construct the binary value from the given inspector. Falls back to UTF8 encoding when the value cannot be coerced into binary.

Returns:

Binary value when possible, utf8 otherwise

Throws:

IOException