org.apache.drill.exec.store.hbase

Class CompareFunctionsProcessor

java.lang.Object

org.apache.drill.common.expression.visitors.AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

org.apache.drill.exec.store.hbase.CompareFunctionsProcessor

All Implemented Interfaces:

ExprVisitor<Boolean,LogicalExpression,RuntimeException>

public class CompareFunctionsProcessor
extends AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

Constructor Summary

Constructors

Constructor and Description
CompareFunctionsProcessor(String functionName)

Method Summary

Modifier and Type	Method and Description
static CompareFunctionsProcessor	createFunctionsProcessorInstance(FunctionCall call, boolean nullComparatorSupported)
protected static <T extends CompareFunctionsProcessor> T	createFunctionsProcessorInstanceInternal(FunctionCall call, boolean nullComparatorSupported, T evaluator)
protected io.netty.buffer.ByteBuf	getByteBuf(LogicalExpression valueArg, String encodingType)
String	getFunctionName()
SchemaPath	getPath()
org.apache.hadoop.hbase.filter.Filter	getRowKeyPrefixFilter()
byte[]	getRowKeyPrefixStartRow()
byte[]	getRowKeyPrefixStopRow()
byte[]	getValue()
static boolean	isCompareFunction(String functionName)
boolean	isRowKeyPrefixComparison()
boolean	isSortOrderAscending()
boolean	isSuccess()
protected static io.netty.buffer.ByteBuf	newByteBuf(int size, boolean bigEndian)
protected void	setFunctionName(String functionName)
protected void	setPath(SchemaPath path)
protected void	setSortOrderAscending(boolean sortOrderAscending)
protected void	setSuccess(boolean success)
Boolean	visitCastExpression(CastExpression e, LogicalExpression valueArg)
Boolean	visitConvertExpression(ConvertExpression e, LogicalExpression valueArg)
Boolean	visitFunctionCall(FunctionCall call, LogicalExpression valueArg)
Boolean	visitSchemaPath(SchemaPath path, LogicalExpression valueArg)
Boolean	visitUnknown(LogicalExpression e, LogicalExpression valueArg) Handles implementation-specific expressions not known to the visitor structure.

Methods inherited from class org.apache.drill.common.expression.visitors.AbstractExprVisitor

visitAnyValueExpression, visitBooleanConstant, visitBooleanOperator, visitDateConstant, visitDecimal18Constant, visitDecimal28Constant, visitDecimal38Constant, visitDecimal9Constant, visitDoubleConstant, visitFloatConstant, visitFunctionHolderExpression, visitIfExpression, visitIntConstant, visitIntervalDayConstant, visitIntervalYearConstant, visitLongConstant, visitNullConstant, visitNullExpression, visitParameter, visitQuotedStringConstant, visitTimeConstant, visitTimeStampConstant, visitTypedFieldExpr, visitVarDecimalConstant

Methods inherited from class java.lang.Object

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

Constructor Detail

CompareFunctionsProcessor

public CompareFunctionsProcessor(String functionName)

Method Detail

isCompareFunction

public static boolean isCompareFunction(String functionName)

createFunctionsProcessorInstance

public static CompareFunctionsProcessor createFunctionsProcessorInstance(FunctionCall call,
                                                                         boolean nullComparatorSupported)

createFunctionsProcessorInstanceInternal

protected static <T extends CompareFunctionsProcessor> T createFunctionsProcessorInstanceInternal(FunctionCall call,
                                                                                                  boolean nullComparatorSupported,
                                                                                                  T evaluator)

getValue

public byte[] getValue()

isSuccess

public boolean isSuccess()

setSuccess

protected void setSuccess(boolean success)

getPath

public SchemaPath getPath()

setPath

protected void setPath(SchemaPath path)

getFunctionName

public String getFunctionName()

setFunctionName

protected void setFunctionName(String functionName)

isRowKeyPrefixComparison

public boolean isRowKeyPrefixComparison()

getRowKeyPrefixStartRow

public byte[] getRowKeyPrefixStartRow()

getRowKeyPrefixStopRow

public byte[] getRowKeyPrefixStopRow()

getRowKeyPrefixFilter

public org.apache.hadoop.hbase.filter.Filter getRowKeyPrefixFilter()

isSortOrderAscending

public boolean isSortOrderAscending()

setSortOrderAscending

protected void setSortOrderAscending(boolean sortOrderAscending)

visitCastExpression

public Boolean visitCastExpression(CastExpression e,
                                   LogicalExpression valueArg)
                            throws RuntimeException

Specified by:

visitCastExpression in interface ExprVisitor<Boolean,LogicalExpression,RuntimeException>

Overrides:

visitCastExpression in class AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

Throws:

RuntimeException

visitConvertExpression

public Boolean visitConvertExpression(ConvertExpression e,
                                      LogicalExpression valueArg)
                               throws RuntimeException

Specified by:

visitConvertExpression in interface ExprVisitor<Boolean,LogicalExpression,RuntimeException>

Overrides:

visitConvertExpression in class AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

Throws:

RuntimeException

getByteBuf

protected io.netty.buffer.ByteBuf getByteBuf(LogicalExpression valueArg,
                                             String encodingType)

visitUnknown

public Boolean visitUnknown(LogicalExpression e,
                            LogicalExpression valueArg)
                     throws RuntimeException

Description copied from class: AbstractExprVisitor

Handles implementation-specific expressions not known to the visitor structure. Since there are no "visitFoo" methods for these "unknown" expressions, subclassses should use the functionally-equivalent instanceof approach to parse out these "unknown" expressions.

Specified by:

visitUnknown in interface ExprVisitor<Boolean,LogicalExpression,RuntimeException>

Overrides:

visitUnknown in class AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

Throws:

RuntimeException

visitSchemaPath

public Boolean visitSchemaPath(SchemaPath path,
                               LogicalExpression valueArg)
                        throws RuntimeException

Specified by:

visitSchemaPath in interface ExprVisitor<Boolean,LogicalExpression,RuntimeException>

Overrides:

visitSchemaPath in class AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

Throws:

RuntimeException

visitFunctionCall

public Boolean visitFunctionCall(FunctionCall call,
                                 LogicalExpression valueArg)

Specified by:

visitFunctionCall in interface ExprVisitor<Boolean,LogicalExpression,RuntimeException>

Overrides:

visitFunctionCall in class AbstractExprVisitor<Boolean,LogicalExpression,RuntimeException>

newByteBuf

protected static io.netty.buffer.ByteBuf newByteBuf(int size,
                                                    boolean bigEndian)