org.apache.hadoop.hbase.spark

Class SparkSQLPushDownFilter

java.lang.Object

FilterBase

org.apache.hadoop.hbase.spark.SparkSQLPushDownFilter

public class SparkSQLPushDownFilter
extends FilterBase

This filter will push down all qualifier logic given to us by SparkSQL so that we have make the filters at the region server level and avoid sending the data back to the client to be filtered.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	log

Constructor Summary

Constructors

Constructor and Description
SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression, byte[][] valueFromQueryArray, <any> fields, java.lang.String encoderClassName)
SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression, byte[][] valueFromQueryArray, java.util.HashMap<ByteArrayComparable,java.util.HashMap<ByteArrayComparable,java.lang.String>> currentCellToColumnIndexMap, java.lang.String encoderClassName)

Method Summary

Modifier and Type	Method and Description
ReturnCode	filterKeyValue(Cell c)
boolean	filterRow()
static SparkSQLPushDownFilter	parseFrom(byte[] pbBytes)
byte[]	toByteArray()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final Log log

Constructor Detail

SparkSQLPushDownFilter

public SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression,
                              byte[][] valueFromQueryArray,
                              java.util.HashMap<ByteArrayComparable,java.util.HashMap<ByteArrayComparable,java.lang.String>> currentCellToColumnIndexMap,
                              java.lang.String encoderClassName)

SparkSQLPushDownFilter

public SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression,
                              byte[][] valueFromQueryArray,
                              <any> fields,
                              java.lang.String encoderClassName)

Method Detail

filterKeyValue

public ReturnCode filterKeyValue(Cell c)
                          throws java.io.IOException

Throws:

java.io.IOException

filterRow

public boolean filterRow()
                  throws java.io.IOException

Throws:

java.io.IOException

parseFrom

public static SparkSQLPushDownFilter parseFrom(byte[] pbBytes)
                                        throws DeserializationException

Parameters:

pbBytes - A pb serialized instance

Returns:

An instance of SparkSQLPushDownFilter

Throws:

org.apache.hadoop.hbase.exceptions.DeserializationException

DeserializationException

toByteArray

public byte[] toByteArray()

Returns:

The filter serialized using pb