public class SparkSQLPushDownFilter
extends FilterBase
Modifier and Type | Field and Description |
---|---|
protected static Log |
log |
Constructor and Description |
---|
SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression,
byte[][] valueFromQueryArray,
<any> fields,
String encoderClassName) |
SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression,
byte[][] valueFromQueryArray,
HashMap<ByteArrayComparable,HashMap<ByteArrayComparable,String>> currentCellToColumnIndexMap,
String encoderClassName) |
Modifier and Type | Method and Description |
---|---|
ReturnCode |
filterKeyValue(Cell c) |
boolean |
filterRow() |
static SparkSQLPushDownFilter |
parseFrom(byte[] pbBytes) |
byte[] |
toByteArray() |
public SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression, byte[][] valueFromQueryArray, HashMap<ByteArrayComparable,HashMap<ByteArrayComparable,String>> currentCellToColumnIndexMap, String encoderClassName)
public SparkSQLPushDownFilter(DynamicLogicExpression dynamicLogicExpression, byte[][] valueFromQueryArray, <any> fields, String encoderClassName)
public ReturnCode filterKeyValue(Cell c) throws IOException
IOException
public boolean filterRow() throws IOException
IOException
public static SparkSQLPushDownFilter parseFrom(byte[] pbBytes) throws DeserializationException
pbBytes
- A pb serialized instanceorg.apache.hadoop.hbase.exceptions.DeserializationException
DeserializationException
public byte[] toByteArray()