org.apache.kudu.client

Class KuduPredicate

java.lang.Object

org.apache.kudu.client.KuduPredicate

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class KuduPredicate
extends Object

A predicate which can be used to filter rows based on the value of a column.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KuduPredicate.ComparisonOp The comparison operator of a predicate.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, BigDecimal value) Creates a new comparison predicate on a Decimal column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, boolean value) Creates a new KuduPredicate on a boolean column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, byte[] value) Creates a new comparison predicate on a binary column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, Date value) Creates a new comparison predicate on a date column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, double value) Creates a new comparison predicate on a double column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, float value) Creates a new comparison predicate on a float column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, long value) Creates a new comparison predicate on an integer or timestamp column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, Object value) Creates a new comparison predicate on a column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, String value) Creates a new comparison predicate on a string column.
static KuduPredicate	newComparisonPredicate(ColumnSchema column, KuduPredicate.ComparisonOp op, Timestamp value) Creates a new comparison predicate on a timestamp column.
static <T> KuduPredicate	newInListPredicate(ColumnSchema column, List<T> values) Creates a new IN list predicate.
static KuduPredicate	newIsNotNullPredicate(ColumnSchema column) Creates a new IS NOT NULL predicate.
static KuduPredicate	newIsNullPredicate(ColumnSchema column) Creates a new IS NULL predicate.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   boolean value)

Creates a new KuduPredicate on a boolean column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   long value)

Creates a new comparison predicate on an integer or timestamp column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   BigDecimal value)

Creates a new comparison predicate on a Decimal column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   Timestamp value)

Creates a new comparison predicate on a timestamp column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   Date value)

Creates a new comparison predicate on a date column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   float value)

Creates a new comparison predicate on a float column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   double value)

Creates a new comparison predicate on a double column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   String value)

Creates a new comparison predicate on a string column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   byte[] value)

Creates a new comparison predicate on a binary column.

Parameters:

column - the column schema

op - the comparison operation

value - the value to compare against

newComparisonPredicate

public static KuduPredicate newComparisonPredicate(ColumnSchema column,
                                                   KuduPredicate.ComparisonOp op,
                                                   Object value)

Creates a new comparison predicate on a column. This method is useful when you don't care about autoboxing and your existing type handling logic is based on Java types. The accepted Object type is based on the column's Type: Type.BOOL -> java.lang.Boolean Type.INT8 -> java.lang.Byte Type.INT16 -> java.lang.Short Type.INT32 -> java.lang.Integer Type.INT64 -> java.lang.Long Type.UNIXTIME_MICROS -> java.sql.Timestamp or java.lang.Long Type.FLOAT -> java.lang.Float Type.DOUBLE -> java.lang.Double Type.STRING -> java.lang.String Type.VARCHAR -> java.lang.String Type.BINARY -> byte[] Type.DECIMAL -> java.math.BigDecimal Type.DATE -> java.sql.Date

Parameters:

column - column the column schema

op - the comparison operation

value - the value to compare against

newInListPredicate

public static <T> KuduPredicate newInListPredicate(ColumnSchema column,
                                                   List<T> values)

Creates a new IN list predicate. The list must contain values of the correct type for the column.

Type Parameters:

T - the type of values, must match the type of the column

Parameters:

column - the column that the predicate applies to

values - list of values which the column values must match

Returns:

an IN list predicate

newIsNotNullPredicate

public static KuduPredicate newIsNotNullPredicate(ColumnSchema column)

Creates a new IS NOT NULL predicate.

Parameters:

column - the column that the predicate applies to

Returns:

an IS NOT NULL predicate

newIsNullPredicate

public static KuduPredicate newIsNullPredicate(ColumnSchema column)

Creates a new IS NULL predicate.

Parameters:

column - the column that the predicate applies to

Returns:

an IS NULL predicate

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object