Package org.apache.iceberg.expressions

Class Expressions

java.lang.Object

org.apache.iceberg.expressions.Expressions

public class Expressions
extends Object

Factory methods for creating expressions.

Method Summary

Modifier and Type	Method	Description
static False	alwaysFalse()
static True	alwaysTrue()
static Expression	and(Expression left, Expression right)
static Expression	and(Expression left, Expression right, Expression... expressions)
static <T> UnboundTerm<T>	bucket(String name, int numBuckets)
static <T> UnboundAggregate<T>	count(String name)
static <T> UnboundAggregate<T>	countStar()
static <T> UnboundTerm<T>	day(String name)
static <T> UnboundPredicate<T>	equal(String name, T value)
static <T> UnboundPredicate<T>	equal(UnboundTerm<T> expr, T value)
static <T> UnboundTerm<T>	extract(String name, String path, String type)
static <T> UnboundPredicate<T>	greaterThan(String name, T value)
static <T> UnboundPredicate<T>	greaterThan(UnboundTerm<T> expr, T value)
static <T> UnboundPredicate<T>	greaterThanOrEqual(String name, T value)
static <T> UnboundPredicate<T>	greaterThanOrEqual(UnboundTerm<T> expr, T value)
static <T> UnboundTerm<T>	hour(String name)
static <T> UnboundPredicate<T>	in(String name, Iterable<T> values)
static <T> UnboundPredicate<T>	in(String name, T... values)
static <T> UnboundPredicate<T>	in(UnboundTerm<T> expr, Iterable<T> values)
static <T> UnboundPredicate<T>	in(UnboundTerm<T> expr, T... values)
static <T> UnboundPredicate<T>	isNaN(String name)
static <T> UnboundPredicate<T>	isNaN(UnboundTerm<T> expr)
static <T> UnboundPredicate<T>	isNull(String name)
static <T> UnboundPredicate<T>	isNull(UnboundTerm<T> expr)
static <T> UnboundPredicate<T>	lessThan(String name, T value)
static <T> UnboundPredicate<T>	lessThan(UnboundTerm<T> expr, T value)
static <T> UnboundPredicate<T>	lessThanOrEqual(String name, T value)
static <T> UnboundPredicate<T>	lessThanOrEqual(UnboundTerm<T> expr, T value)
static <T> Literal<T>	lit(T value)	Create a Literal from an Object.
static <T> UnboundAggregate<T>	max(String name)
static Literal<Long>	micros(long micros)	Create a Literal from a microsecond value.
static Literal<Long>	millis(long millis)	Create a Literal from a millisecond value.
static <T> UnboundAggregate<T>	min(String name)
static <T> UnboundTerm<T>	month(String name)
static Literal<Long>	nanos(long nanos)	Create a Literal from a nanosecond value.
static Expression	not(Expression child)
static <T> UnboundPredicate<T>	notEqual(String name, T value)
static <T> UnboundPredicate<T>	notEqual(UnboundTerm<T> expr, T value)
static <T> UnboundPredicate<T>	notIn(String name, Iterable<T> values)
static <T> UnboundPredicate<T>	notIn(String name, T... values)
static <T> UnboundPredicate<T>	notIn(UnboundTerm<T> expr, Iterable<T> values)
static <T> UnboundPredicate<T>	notIn(UnboundTerm<T> expr, T... values)
static <T> UnboundPredicate<T>	notNaN(String name)
static <T> UnboundPredicate<T>	notNaN(UnboundTerm<T> expr)
static <T> UnboundPredicate<T>	notNull(String name)
static <T> UnboundPredicate<T>	notNull(UnboundTerm<T> expr)
static UnboundPredicate<String>	notStartsWith(String name, String value)
static UnboundPredicate<String>	notStartsWith(UnboundTerm<String> expr, String value)
static Expression	or(Expression left, Expression right)
static <T> UnboundPredicate<T>	predicate(Expression.Operation op, String name)
static <T> UnboundPredicate<T>	predicate(Expression.Operation op, String name, Iterable<T> values)
static <T> UnboundPredicate<T>	predicate(Expression.Operation op, String name, Literal<T> lit)
static <T> UnboundPredicate<T>	predicate(Expression.Operation op, String name, T value)
static <T> UnboundPredicate<T>	predicate(Expression.Operation op, UnboundTerm<T> expr)
static <T> UnboundPredicate<T>	predicate(Expression.Operation op, UnboundTerm<T> expr, Iterable<T> values)
static <T> NamedReference<T>	ref(String name)	Constructs a reference for a given column.
static Expression	rewriteNot(Expression expr)
static UnboundPredicate<String>	startsWith(String name, String value)
static UnboundPredicate<String>	startsWith(UnboundTerm<String> expr, String value)
static <T> UnboundTerm<T>	transform(String name, Transform<?,T> transform)	Constructs a transform expression for a given column.
static <T> UnboundTerm<T>	truncate(String name, int width)
static <T> UnboundTerm<T>	year(String name)

Methods inherited from class java.lang.Object

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

Method Details

and

public static Expression and(Expression left,
 Expression right)

and

public static Expression and(Expression left,
 Expression right,
 Expression... expressions)

or

public static Expression or(Expression left,
 Expression right)

not

public static Expression not(Expression child)

bucket

public static <T> UnboundTerm<T> bucket(String name,
 int numBuckets)

year

public static <T> UnboundTerm<T> year(String name)

month

public static <T> UnboundTerm<T> month(String name)

day

public static <T> UnboundTerm<T> day(String name)

hour

public static <T> UnboundTerm<T> hour(String name)

truncate

public static <T> UnboundTerm<T> truncate(String name,
 int width)

extract

public static <T> UnboundTerm<T> extract(String name,
 String path,
 String type)

isNull

public static <T> UnboundPredicate<T> isNull(String name)

isNull

public static <T> UnboundPredicate<T> isNull(UnboundTerm<T> expr)

notNull

public static <T> UnboundPredicate<T> notNull(String name)

notNull

public static <T> UnboundPredicate<T> notNull(UnboundTerm<T> expr)

isNaN

public static <T> UnboundPredicate<T> isNaN(String name)

isNaN

public static <T> UnboundPredicate<T> isNaN(UnboundTerm<T> expr)

notNaN

public static <T> UnboundPredicate<T> notNaN(String name)

notNaN

public static <T> UnboundPredicate<T> notNaN(UnboundTerm<T> expr)

lessThan

public static <T> UnboundPredicate<T> lessThan(String name,
 T value)

lessThan

public static <T> UnboundPredicate<T> lessThan(UnboundTerm<T> expr,
 T value)

lessThanOrEqual

public static <T> UnboundPredicate<T> lessThanOrEqual(String name,
 T value)

lessThanOrEqual

public static <T> UnboundPredicate<T> lessThanOrEqual(UnboundTerm<T> expr,
 T value)

greaterThan

public static <T> UnboundPredicate<T> greaterThan(String name,
 T value)

greaterThan

public static <T> UnboundPredicate<T> greaterThan(UnboundTerm<T> expr,
 T value)

greaterThanOrEqual

public static <T> UnboundPredicate<T> greaterThanOrEqual(String name,
 T value)

greaterThanOrEqual

public static <T> UnboundPredicate<T> greaterThanOrEqual(UnboundTerm<T> expr,
 T value)

equal

public static <T> UnboundPredicate<T> equal(String name,
 T value)

equal

public static <T> UnboundPredicate<T> equal(UnboundTerm<T> expr,
 T value)

notEqual

public static <T> UnboundPredicate<T> notEqual(String name,
 T value)

notEqual

public static <T> UnboundPredicate<T> notEqual(UnboundTerm<T> expr,
 T value)

startsWith

public static UnboundPredicate<String> startsWith(String name,
 String value)

startsWith

public static UnboundPredicate<String> startsWith(UnboundTerm<String> expr,
 String value)

notStartsWith

public static UnboundPredicate<String> notStartsWith(String name,
 String value)

notStartsWith

public static UnboundPredicate<String> notStartsWith(UnboundTerm<String> expr,
 String value)

in

public static <T> UnboundPredicate<T> in(String name,
 T... values)

in

public static <T> UnboundPredicate<T> in(UnboundTerm<T> expr,
 T... values)

in

public static <T> UnboundPredicate<T> in(String name,
 Iterable<T> values)

in

public static <T> UnboundPredicate<T> in(UnboundTerm<T> expr,
 Iterable<T> values)

notIn

public static <T> UnboundPredicate<T> notIn(String name,
 T... values)

notIn

public static <T> UnboundPredicate<T> notIn(UnboundTerm<T> expr,
 T... values)

notIn

public static <T> UnboundPredicate<T> notIn(String name,
 Iterable<T> values)

notIn

public static <T> UnboundPredicate<T> notIn(UnboundTerm<T> expr,
 Iterable<T> values)

predicate

public static <T> UnboundPredicate<T> predicate(Expression.Operation op,
 String name,
 T value)

predicate

public static <T> UnboundPredicate<T> predicate(Expression.Operation op,
 String name,
 Literal<T> lit)

predicate

public static <T> UnboundPredicate<T> predicate(Expression.Operation op,
 String name,
 Iterable<T> values)

predicate

public static <T> UnboundPredicate<T> predicate(Expression.Operation op,
 String name)

predicate

public static <T> UnboundPredicate<T> predicate(Expression.Operation op,
 UnboundTerm<T> expr,
 Iterable<T> values)

predicate

public static <T> UnboundPredicate<T> predicate(Expression.Operation op,
 UnboundTerm<T> expr)

alwaysTrue

public static True alwaysTrue()

alwaysFalse

public static False alwaysFalse()

rewriteNot

public static Expression rewriteNot(Expression expr)

ref

public static <T> NamedReference<T> ref(String name)

Constructs a reference for a given column.

The following are equivalent: equals("a", 5) and equals(ref("a"), 5).

Type Parameters:

T - the Java type of this reference

Parameters:

name - a column name

Returns:

a named reference

transform

public static <T> UnboundTerm<T> transform(String name,
 Transform<?,T> transform)

Constructs a transform expression for a given column.

Type Parameters:

T - the Java type of this term

Parameters:

name - a column name

transform - a transform function

Returns:

an unbound transform expression

lit

public static <T> Literal<T> lit(T value)

Create a Literal from an Object.

Type Parameters:

T - Java type of value

Parameters:

value - a value

Returns:

a Literal for the given value

Throws:

IllegalArgumentException - if the value has no literal implementation

micros

public static Literal<Long> micros(long micros)

Create a Literal from a microsecond value.

Parameters:

micros - a timestamp in microseconds from the unix epoch

Returns:

a literal representing the timestamp

millis

public static Literal<Long> millis(long millis)

Create a Literal from a millisecond value.

Parameters:

millis - a timestamp in milliseconds from the unix epoch

Returns:

a literal representing the timestamp

nanos

public static Literal<Long> nanos(long nanos)

Create a Literal from a nanosecond value.

Parameters:

nanos - a timestamp in nanoseconds from the unix epoch

Returns:

a literal representing the timestamp

count

public static <T> UnboundAggregate<T> count(String name)

countStar

public static <T> UnboundAggregate<T> countStar()

max

public static <T> UnboundAggregate<T> max(String name)

min

public static <T> UnboundAggregate<T> min(String name)