org.apache.hawq.pxf.plugins.hbase.utilities

Class HBaseIntegerComparator

java.lang.Object

org.apache.hadoop.hbase.filter.ByteArrayComparable

org.apache.hawq.pxf.plugins.hbase.utilities.HBaseIntegerComparator

All Implemented Interfaces:

java.lang.Comparable<byte[]>

public class HBaseIntegerComparator
extends org.apache.hadoop.hbase.filter.ByteArrayComparable

This is a Filter comparator for HBase It is external to PXF HBase code.

To use with HBase it must reside in the classpath of every region server.

It converts a value into Long before comparing. The filter is good for any integer numeric comparison i.e. integer, bigint, smallint.

according to HBase 0.96 requirements, this must serialized using Protocol Buffers (toByteArray() and parseFrom(byte[]) methods).

A reference can be found in SubstringComparator.

Constructor Summary

Constructors

Constructor and Description
HBaseIntegerComparator(java.lang.Long inVal)

Method Summary

Modifier and Type	Method and Description
int	compareTo(byte[] value, int offset, int length) The comparison function.
static org.apache.hadoop.hbase.filter.ByteArrayComparable	parseFrom(byte[] pbBytes) Hides ("overrides") a static method in ByteArrayComparable.
byte[]	toByteArray() Returns the comparator serialized using Protocol Buffers.

Methods inherited from class org.apache.hadoop.hbase.filter.ByteArrayComparable

compareTo, getValue

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseIntegerComparator

public HBaseIntegerComparator(java.lang.Long inVal)

Method Detail

compareTo

public int compareTo(byte[] value,
                     int offset,
                     int length)

The comparison function. Currently uses Long.parseLong(String).

Specified by:

compareTo in class org.apache.hadoop.hbase.filter.ByteArrayComparable

Returns:

0 if equal; a value less than 0 if row value is less than filter value; and a value greater than 0 if the row value is greater than the filter value.

toByteArray

public byte[] toByteArray()

Returns the comparator serialized using Protocol Buffers.

Specified by:

toByteArray in class org.apache.hadoop.hbase.filter.ByteArrayComparable

Returns:

serialized comparator

parseFrom

public static org.apache.hadoop.hbase.filter.ByteArrayComparable parseFrom(byte[] pbBytes)
                                                                    throws org.apache.hadoop.hbase.exceptions.DeserializationException

Hides ("overrides") a static method in ByteArrayComparable. This method will be called in deserialization.

Parameters:

pbBytes - A pb serialized instance

Returns:

An instance of HBaseIntegerComparator made from bytes

Throws:

org.apache.hadoop.hbase.exceptions.DeserializationException - if deserialization of bytes to Protocol Buffers failed

See Also:

toByteArray()