Package org.apache.calcite.linq4j

Class QueryProviderImpl.QueryableImpl<T>

java.lang.Object

org.apache.calcite.linq4j.DefaultEnumerable<T>

org.apache.calcite.linq4j.AbstractQueryable<TSource>

org.apache.calcite.linq4j.BaseQueryable<T>

org.apache.calcite.linq4j.QueryProviderImpl.QueryableImpl<T>

Type Parameters:

T - element type

All Implemented Interfaces:

Iterable<T>, Enumerable<T>, ExtendedEnumerable<T>, ExtendedOrderedEnumerable<T>, ExtendedOrderedQueryable<T>, OrderedEnumerable<T>, OrderedQueryable<T>, Queryable<T>, RawEnumerable<T>, RawQueryable<T>

Enclosing class:

QueryProviderImpl

public static class QueryProviderImpl.QueryableImpl<T>
extends BaseQueryable<T>

Binds an expression to this query provider.

Field Summary

Fields inherited from class org.apache.calcite.linq4j.BaseQueryable

elementType, expression, provider

Constructor Summary

Constructors

Constructor	Description
QueryableImpl(QueryProviderImpl provider, Type elementType, Expression expression)

Method Summary

Modifier and Type	Method	Description
T	aggregate(FunctionExpression<Function2<T,T,T>> selector)
T	aggregate(FunctionExpression<Function2<T,T,T>> selector)	Applies an accumulator function over a sequence.
<TAccumulate> TAccumulate	aggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,T,TAccumulate>> selector)
<TAccumulate, TResult> TResult	aggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,T,TAccumulate>> func, FunctionExpression<Function1<TAccumulate,TResult>> selector)
<TAccumulate> TAccumulate	aggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,T,TAccumulate>> selector)	Applies an accumulator function over a sequence.
<TAccumulate, TResult> TResult	aggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,T,TAccumulate>> func, FunctionExpression<Function1<TAccumulate,TResult>> selector)	Applies an accumulator function over a sequence.
boolean	all(FunctionExpression<Predicate1<T>> predicate)
boolean	all(FunctionExpression<Predicate1<T>> predicate)	Determines whether all the elements of a sequence satisfy a condition.
boolean	any(FunctionExpression<Predicate1<T>> predicate)
boolean	any(FunctionExpression<Predicate1<T>> predicate)	Determines whether any element of a sequence satisfies a condition.
Enumerable<T>	asEnumerable()	Returns the input typed as Enumerable<TSource>.
Queryable<T>	asQueryable()	Converts this Enumerable to a Queryable.
BigDecimal	averageBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)
BigDecimal	averageBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)	Computes the average of a sequence of Decimal values that is obtained by invoking a projection function on each element of the input sequence.
double	averageDouble(FunctionExpression<DoubleFunction1<T>> selector)
double	averageDouble(FunctionExpression<DoubleFunction1<T>> selector)	Computes the average of a sequence of Double values that is obtained by invoking a projection function on each element of the input sequence.
float	averageFloat(FunctionExpression<FloatFunction1<T>> selector)
float	averageFloat(FunctionExpression<FloatFunction1<T>> selector)	Computes the average of a sequence of Float values that is obtained by invoking a projection function on each element of the input sequence.
int	averageInteger(FunctionExpression<IntegerFunction1<T>> selector)
int	averageInteger(FunctionExpression<IntegerFunction1<T>> selector)	Computes the average of a sequence of int values that is obtained by invoking a projection function on each element of the input sequence.
long	averageLong(FunctionExpression<LongFunction1<T>> selector)
long	averageLong(FunctionExpression<LongFunction1<T>> selector)	Computes the average of a sequence of long values that is obtained by invoking a projection function on each element of the input sequence.
BigDecimal	averageNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)
BigDecimal	averageNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)	Computes the average of a sequence of nullable Decimal values that is obtained by invoking a projection function on each element of the input sequence.
Double	averageNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)
Double	averageNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)	Computes the average of a sequence of nullable Double values that is obtained by invoking a projection function on each element of the input sequence.
Float	averageNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)
Float	averageNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)	Computes the average of a sequence of nullable Float values that is obtained by invoking a projection function on each element of the input sequence.
Integer	averageNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)
Integer	averageNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)	Computes the average of a sequence of nullable int values that is obtained by invoking a projection function on each element of the input sequence.
Long	averageNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)
Long	averageNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)	Computes the average of a sequence of nullable long values that is obtained by invoking a projection function on each element of the input sequence.
<T2> Queryable<T2>	cast(Class<T2> clazz)	Converts the elements of this Enumerable to the specified type.
<T2> Queryable<T2>	cast(Class<T2> clazz)	Converts the elements of this Enumerable to the specified type.
Queryable<T>	concat(Enumerable<T> source2)	Concatenates two sequences.
Queryable<T>	concat(Enumerable<T> source2)	Concatenates two sequences.
int	count(FunctionExpression<Predicate1<T>> func)
int	count(FunctionExpression<Predicate1<T>> predicate)	Returns the number of elements in the specified sequence that satisfies a condition.
Queryable<T>	defaultIfEmpty()	Returns the elements of the specified sequence or the type parameter's default value in a singleton collection if the sequence is empty.
Queryable<T>	defaultIfEmpty()	Returns the elements of the specified sequence or the type parameter's default value in a singleton collection if the sequence is empty.
Queryable<T>	distinct()	Returns distinct elements from a sequence by using the default equality comparer to compare values.
Queryable<T>	distinct()	Returns distinct elements from a sequence by using the default equality comparer to compare values.
Queryable<T>	distinct(EqualityComparer<T> comparer)	Returns distinct elements from a sequence by using a specified EqualityComparer<TSource> to compare values.
Queryable<T>	distinct(EqualityComparer<T> comparer)	Returns distinct elements from a sequence by using a specified EqualityComparer<TSource> to compare values.
Queryable<T>	except(Enumerable<T> enumerable1)	Produces the set difference of two sequences by using the default equality comparer to compare values, eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable1, boolean all)	Produces the set difference of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable1, EqualityComparer<T> comparer)	Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable1, EqualityComparer<T> comparer, boolean all)	Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable)	Produces the set difference of two sequences by using the default equality comparer to compare values, eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable, boolean all)	Produces the set difference of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable, EqualityComparer<T> comparer)	Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.
Queryable<T>	except(Enumerable<T> enumerable, EqualityComparer<T> comparer, boolean all)	Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.
T	first(FunctionExpression<Predicate1<T>> predicate)
T	first(FunctionExpression<Predicate1<T>> predicate)	Returns the first element of a sequence that satisfies a specified condition.
T	firstOrDefault(FunctionExpression<Predicate1<T>> predicate)
T	firstOrDefault(FunctionExpression<Predicate1<T>> predicate)	Returns the first element of a sequence that satisfies a specified condition or a default value if no such element is found.
protected Queryable<T>	getThis()	Derived classes might wish to override this method to return the "outer" enumerable.
protected OrderedQueryable<T>	getThisOrderedQueryable()
<TKey> Queryable<Grouping<TKey,T>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector)
<TKey> Queryable<Grouping<TKey,T>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, EqualityComparer<TKey> comparer)
<TKey, TElement> Queryable<Grouping<TKey,TElement>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector)
<TKey, TElement> Queryable<Grouping<TKey,TElement>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector, EqualityComparer<TKey> comparer)
<TKey, TElement, TResult> Queryable<TResult>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector, FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector)
<TKey, TElement, TResult> Queryable<TResult>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector, FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector, EqualityComparer<TKey> comparer)
<TKey> Queryable<Grouping<TKey,T>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector)	Groups the elements of a sequence according to a specified key selector function.
<TKey> Queryable<Grouping<TKey,T>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, EqualityComparer<TKey> comparer)	Groups the elements of a sequence according to a specified key selector function and compares the keys by using a specified comparer.
<TKey, TElement> Queryable<Grouping<TKey,TElement>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector)	Groups the elements of a sequence according to a specified key selector function and projects the elements for each group by using a specified function.
<TKey, TElement> Queryable<Grouping<TKey,TElement>>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector, EqualityComparer<TKey> comparer)	Groups the elements of a sequence and projects the elements for each group by using a specified function.
<TKey, TElement, TResult> Queryable<TResult>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector, FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector)	Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key.
<TKey, TElement, TResult> Queryable<TResult>	groupBy(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function1<T,TElement>> elementSelector, FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector, EqualityComparer<TKey> comparer)	Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key.
<TKey, TResult> Queryable<TResult>	groupByK(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector)
<TKey, TResult> Queryable<TResult>	groupByK(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector, EqualityComparer<TKey> comparer)
<TKey, TResult> Queryable<TResult>	groupByK(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector)	Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key.
<TKey, TResult> Queryable<TResult>	groupByK(FunctionExpression<Function1<T,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector, EqualityComparer<TKey> comparer)	Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key.
<TInner, TKey, TResult> Queryable<TResult>	groupJoin(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector)
<TInner, TKey, TResult> Queryable<TResult>	groupJoin(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector, EqualityComparer<TKey> comparer)
<TInner, TKey, TResult> Queryable<TResult>	groupJoin(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector)	Correlates the elements of two sequences based on key equality and groups the results.
<TInner, TKey, TResult> Queryable<TResult>	groupJoin(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector, EqualityComparer<TKey> comparer)	Correlates the elements of two sequences based on key equality and groups the results.
Queryable<T>	intersect(Enumerable<T> source1)	Produces the set intersection of two sequences by using the default equality comparer to compare values, eliminate duplicates.
Queryable<T>	intersect(Enumerable<T> source1, boolean all)	Produces the set intersection of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates.
Queryable<T>	intersect(Enumerable<T> source1, EqualityComparer<T> comparer)	Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.
Queryable<T>	intersect(Enumerable<T> source1, EqualityComparer<T> comparer, boolean all)	Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.
Queryable<T>	intersect(Enumerable<T> enumerable)	Produces the set intersection of two sequences by using the default equality comparer to compare values, eliminate duplicates.(Defined by Queryable.)
Queryable<T>	intersect(Enumerable<T> enumerable, boolean all)	Produces the set intersection of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates.
Queryable<T>	intersect(Enumerable<T> enumerable, EqualityComparer<T> comparer)	Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.
Queryable<T>	intersect(Enumerable<T> enumerable, EqualityComparer<T> comparer, boolean all)	Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.
<TInner, TKey, TResult> Queryable<TResult>	join(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,TInner,TResult>> resultSelector)
<TInner, TKey, TResult> Queryable<TResult>	join(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,TInner,TResult>> resultSelector, EqualityComparer<TKey> comparer)
<TInner, TKey, TResult> Queryable<TResult>	join(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,TInner,TResult>> resultSelector)	Correlates the elements of two sequences based on matching keys.
<TInner, TKey, TResult> Queryable<TResult>	join(Enumerable<TInner> inner, FunctionExpression<Function1<T,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<T,TInner,TResult>> resultSelector, EqualityComparer<TKey> comparer)	Correlates the elements of two sequences based on matching keys.
T	last(FunctionExpression<Predicate1<T>> predicate)
T	last(FunctionExpression<Predicate1<T>> predicate)	Returns the last element of a sequence that satisfies a specified condition.
T	lastOrDefault(FunctionExpression<Predicate1<T>> predicate)
T	lastOrDefault(FunctionExpression<Predicate1<T>> predicate)	Returns the last element of a sequence that satisfies a condition or a default value if no such element is found.
long	longCount(FunctionExpression<Predicate1<T>> predicate)
long	longCount(FunctionExpression<Predicate1<T>> predicate)	Returns an long that represents the number of elements in a sequence that satisfy a condition.
<TResult extends Comparable<TResult>> TResult	max(FunctionExpression<Function1<T,TResult>> selector)
<TResult extends Comparable<TResult>> @Nullable TResult	max(FunctionExpression<Function1<T,TResult>> selector)	Invokes a projection function on each element of a generic IQueryable<TSource> and returns the maximum resulting value.
<TResult extends Comparable<TResult>> TResult	min(FunctionExpression<Function1<T,TResult>> selector)
<TResult extends Comparable<TResult>> @Nullable TResult	min(FunctionExpression<Function1<T,TResult>> selector)	Invokes a projection function on each element of a generic IQueryable<TSource> and returns the minimum resulting value.
<TResult> Queryable<TResult>	ofType(Class<TResult> clazz)	Filters the elements of an Enumerable based on a specified type.
<TResult> Queryable<TResult>	ofType(Class<TResult> clazz)	Filters the elements of an IQueryable based on a specified type.
<TKey extends Comparable> OrderedQueryable<T>	orderBy(FunctionExpression<Function1<T,TKey>> keySelector)
<TKey> OrderedQueryable<T>	orderBy(FunctionExpression<Function1<T,TKey>> keySelector, Comparator<TKey> comparator)
<TKey extends Comparable> OrderedQueryable<T>	orderBy(FunctionExpression<Function1<T,TKey>> keySelector)	Sorts the elements of a sequence in ascending order according to a key.
<TKey> OrderedQueryable<T>	orderBy(FunctionExpression<Function1<T,TKey>> keySelector, Comparator<TKey> comparator)	Sorts the elements of a sequence in ascending order by using a specified comparer.
<TKey extends Comparable> OrderedQueryable<T>	orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector)
<TKey> OrderedQueryable<T>	orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector, Comparator<TKey> comparator)
<TKey extends Comparable> OrderedQueryable<T>	orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector)	Sorts the elements of a sequence in descending order according to a key.
<TKey> OrderedQueryable<T>	orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector, Comparator<TKey> comparator)	Sorts the elements of a sequence in descending order by using a specified comparer.
Queryable<T>	reverse()	Inverts the order of the elements in a sequence.
Queryable<T>	reverse()	Inverts the order of the elements in a sequence.
<TResult> Queryable<TResult>	select(FunctionExpression<Function1<T,TResult>> selector)
<TResult> Queryable<TResult>	select(FunctionExpression<Function1<T,TResult>> selector)	Projects each element of a sequence into a new form.
<TResult> Queryable<TResult>	selectMany(FunctionExpression<Function1<T,Enumerable<TResult>>> selector)
<TResult> Queryable<TResult>	selectMany(FunctionExpression<Function1<T,Enumerable<TResult>>> selector)	Projects each element of a sequence to an Enumerable<TSource> and combines the resulting sequences into one sequence.
<TCollection, TResult> Queryable<TResult>	selectMany(FunctionExpression<Function2<T,Integer,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)
<TCollection, TResult> Queryable<TResult>	selectMany(FunctionExpression<Function2<T,Integer,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)	Projects each element of a sequence to an Enumerable<TSource> that incorporates the index of the source element that produced it.
<TCollection, TResult> Queryable<TResult>	selectManyN(FunctionExpression<Function1<T,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)
<TCollection, TResult> Queryable<TResult>	selectManyN(FunctionExpression<Function1<T,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)	Projects each element of a sequence to an Enumerable<TSource> and invokes a result selector function on each element therein.
<TResult> Queryable<TResult>	selectManyN(FunctionExpression<Function2<T,Integer,Enumerable<TResult>>> selector)
<TResult> Queryable<TResult>	selectManyN(FunctionExpression<Function2<T,Integer,Enumerable<TResult>>> selector)	Projects each element of a sequence to an Enumerable<TSource> and combines the resulting sequences into one sequence.
<TResult> Queryable<TResult>	selectN(FunctionExpression<Function2<T,Integer,TResult>> selector)
<TResult> Queryable<TResult>	selectN(FunctionExpression<Function2<T,Integer,TResult>> selector)	Projects each element of a sequence into a new form by incorporating the element's index.
T	single(FunctionExpression<Predicate1<T>> predicate)
T	single(FunctionExpression<Predicate1<T>> predicate)	Returns the only element of a sequence that satisfies a specified condition, and throws an exception if more than one such element exists.
T	singleOrDefault()	Returns the only element of a sequence, or a default value if the sequence is empty; this method throws an exception if there is more than one element in the sequence.
T	singleOrDefault(FunctionExpression<Predicate1<T>> predicate)
T	singleOrDefault(FunctionExpression<Predicate1<T>> predicate)	Returns the only element of a sequence that satisfies a specified condition or a default value if no such element exists; this method throws an exception if more than one element satisfies the condition.
Queryable<T>	skip(int count)	Bypasses a specified number of elements in a sequence and then returns the remaining elements.
Queryable<T>	skip(int count)	Bypasses a specified number of elements in a sequence and then returns the remaining elements.
Queryable<T>	skipWhile(FunctionExpression<Predicate1<T>> predicate)
Queryable<T>	skipWhile(FunctionExpression<Predicate1<T>> predicate)	Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements.
Queryable<T>	skipWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)
Queryable<T>	skipWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)	Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements.
BigDecimal	sumBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)
BigDecimal	sumBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)	Computes the sum of the sequence of Decimal values that is obtained by invoking a projection function on each element of the input sequence.
double	sumDouble(FunctionExpression<DoubleFunction1<T>> selector)
double	sumDouble(FunctionExpression<DoubleFunction1<T>> selector)	Computes the sum of the sequence of Double values that is obtained by invoking a projection function on each element of the input sequence.
float	sumFloat(FunctionExpression<FloatFunction1<T>> selector)
float	sumFloat(FunctionExpression<FloatFunction1<T>> selector)	Computes the sum of the sequence of Float values that is obtained by invoking a projection function on each element of the input sequence.
int	sumInteger(FunctionExpression<IntegerFunction1<T>> selector)
int	sumInteger(FunctionExpression<IntegerFunction1<T>> selector)	Computes the sum of the sequence of int values that is obtained by invoking a projection function on each element of the input sequence.
long	sumLong(FunctionExpression<LongFunction1<T>> selector)
long	sumLong(FunctionExpression<LongFunction1<T>> selector)	Computes the sum of the sequence of long values that is obtained by invoking a projection function on each element of the input sequence.
BigDecimal	sumNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)
BigDecimal	sumNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)	Computes the sum of the sequence of nullable Decimal values that is obtained by invoking a projection function on each element of the input sequence.
Double	sumNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)
Double	sumNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)	Computes the sum of the sequence of nullable Double values that is obtained by invoking a projection function on each element of the input sequence.
Float	sumNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)
Float	sumNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)	Computes the sum of the sequence of nullable Float values that is obtained by invoking a projection function on each element of the input sequence.
Integer	sumNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)
Integer	sumNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)	Computes the sum of the sequence of nullable int values that is obtained by invoking a projection function on each element of the input sequence.
Long	sumNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)
Long	sumNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)	Computes the sum of the sequence of nullable long values that is obtained by invoking a projection function on each element of the input sequence.
Queryable<T>	take(int count)	Returns a specified number of contiguous elements from the start of a sequence.
Queryable<T>	take(int count)	Returns a specified number of contiguous elements from the start of a sequence.
Queryable<T>	takeWhile(FunctionExpression<Predicate1<T>> predicate)
Queryable<T>	takeWhile(FunctionExpression<Predicate1<T>> predicate)	Returns elements from a sequence as long as a specified condition is true.
Queryable<T>	takeWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)
Queryable<T>	takeWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)	Returns elements from a sequence as long as a specified condition is true.
<TKey extends Comparable<TKey>> OrderedQueryable<T>	thenBy(FunctionExpression<Function1<T,TKey>> keySelector)	Performs a subsequent ordering of the elements in a sequence in ascending order according to a key.
<TKey> OrderedQueryable<T>	thenBy(FunctionExpression<Function1<T,TKey>> keySelector, Comparator<TKey> comparator)	Performs a subsequent ordering of the elements in a sequence in ascending order according to a key, using a specified comparator.
<TKey extends Comparable<TKey>> OrderedQueryable<T>	thenByDescending(FunctionExpression<Function1<T,TKey>> keySelector)	Performs a subsequent ordering of the elements in a sequence in descending order according to a key.
<TKey> OrderedQueryable<T>	thenByDescending(FunctionExpression<Function1<T,TKey>> keySelector, Comparator<TKey> comparator)	Performs a subsequent ordering of the elements in a sequence in descending order according to a key, using a specified comparator.
String	toString()
Queryable<T>	union(Enumerable<T> source1)	Produces the set union of two sequences by using the default equality comparer.
Queryable<T>	union(Enumerable<T> source1, EqualityComparer<T> comparer)	Produces the set union of two sequences by using a specified EqualityComparer<TSource>.
Queryable<T>	union(Enumerable<T> source1)	Produces the set union of two sequences by using the default equality comparer.
Queryable<T>	union(Enumerable<T> source1, EqualityComparer<T> comparer)	Produces the set union of two sequences by using a specified EqualityComparer<TSource>.
Queryable<T>	where(FunctionExpression<? extends Predicate1<T>> predicate)
Queryable<T>	where(FunctionExpression<? extends Predicate1<T>> predicate)	Filters a sequence of values based on a predicate.
Queryable<T>	whereN(FunctionExpression<? extends Predicate2<T,Integer>> predicate)
Queryable<T>	whereN(FunctionExpression<? extends Predicate2<T,Integer>> predicate)	Filters a sequence of values based on a predicate.
<T1, TResult> Queryable<TResult>	zip(Enumerable<T1> source1, FunctionExpression<Function2<T,T1,TResult>> resultSelector)
<T1, TResult> Queryable<TResult>	zip(Enumerable<T1> source1, FunctionExpression<Function2<T,T1,TResult>> resultSelector)	Merges two sequences by using the specified predicate function.

Methods inherited from class org.apache.calcite.linq4j.BaseQueryable

enumerator, getElementType, getExpression, getProvider, iterator

Methods inherited from class org.apache.calcite.linq4j.DefaultEnumerable

aggregate, aggregate, aggregate, all, any, any, asofJoin, asOrderedQueryable, average, average, average, average, average, average, average, average, average, average, contains, contains, correlateJoin, count, count, createOrderedEnumerable, defaultIfEmpty, elementAt, elementAtOrDefault, first, first, firstOrDefault, firstOrDefault, foreach, getThisOrdered, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupJoin, groupJoin, hashJoin, hashJoin, hashJoin, hashJoin, into, last, last, lastOrDefault, lastOrDefault, longCount, longCount, max, max, max, max, max, max, max, max, max, max, max, max, min, min, min, min, min, min, min, min, min, min, min, min, orderBy, orderBy, orderByDescending, orderByDescending, removeAll, select, select, selectMany, selectMany, selectMany, selectMany, sequenceEqual, sequenceEqual, single, single, singleOrDefault, singleOrDefault, skipWhile, skipWhile, sortedGroupBy, sum, sum, sum, sum, sum, sum, sum, sum, sum, sum, takeWhile, takeWhile, thenBy, thenBy, thenByDescending, thenByDescending, toList, toLookup, toLookup, toLookup, toLookup, toMap, toMap, toMap, toMap, where, where, zip

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.calcite.linq4j.Enumerable

asQueryable

Methods inherited from interface org.apache.calcite.linq4j.ExtendedEnumerable

aggregate, aggregate, aggregate, all, any, any, asEnumerable, asofJoin, average, average, average, average, average, average, average, average, average, average, contains, contains, correlateJoin, count, count, defaultIfEmpty, elementAt, elementAtOrDefault, first, first, firstOrDefault, firstOrDefault, foreach, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupJoin, groupJoin, hashJoin, hashJoin, hashJoin, hashJoin, into, last, last, lastOrDefault, lastOrDefault, longCount, longCount, max, max, max, max, max, max, max, max, max, max, max, max, min, min, min, min, min, min, min, min, min, min, min, min, orderBy, orderBy, orderByDescending, orderByDescending, removeAll, select, select, selectMany, selectMany, selectMany, selectMany, sequenceEqual, sequenceEqual, single, single, singleOrDefault, skipWhile, skipWhile, sortedGroupBy, sum, sum, sum, sum, sum, sum, sum, sum, sum, sum, takeWhile, takeWhile, toList, toLookup, toLookup, toLookup, toLookup, toMap, toMap, toMap, toMap, where, where, zip

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

QueryableImpl

public QueryableImpl(QueryProviderImpl provider,
 Type elementType,
 Expression expression)

Method Details

toString

public String toString()

Overrides:

toString in class Object

aggregate

T aggregate(FunctionExpression<Function2<T,T,T>> selector)

Applies an accumulator function over a sequence.

aggregate

<TAccumulate> TAccumulate aggregate(TAccumulate seed,
 FunctionExpression<Function2<TAccumulate,T,TAccumulate>> selector)

Applies an accumulator function over a sequence. The specified seed value is used as the initial accumulator value.

aggregate

<TAccumulate,
TResult> TResult aggregate(TAccumulate seed,
 FunctionExpression<Function2<TAccumulate,T,TAccumulate>> func,
 FunctionExpression<Function1<TAccumulate,TResult>> selector)

Applies an accumulator function over a sequence. The specified seed value is used as the initial accumulator value, and the specified function is used to select the result value.

all

boolean all(FunctionExpression<Predicate1<T>> predicate)

Determines whether all the elements of a sequence satisfy a condition.

any

boolean any(FunctionExpression<Predicate1<T>> predicate)

Determines whether any element of a sequence satisfies a condition.

averageBigDecimal

BigDecimal averageBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)

Computes the average of a sequence of Decimal values that is obtained by invoking a projection function on each element of the input sequence.

averageNullableBigDecimal

BigDecimal averageNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)

Computes the average of a sequence of nullable Decimal values that is obtained by invoking a projection function on each element of the input sequence.

averageDouble

double averageDouble(FunctionExpression<DoubleFunction1<T>> selector)

Computes the average of a sequence of Double values that is obtained by invoking a projection function on each element of the input sequence.

averageNullableDouble

Double averageNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)

Computes the average of a sequence of nullable Double values that is obtained by invoking a projection function on each element of the input sequence.

averageInteger

int averageInteger(FunctionExpression<IntegerFunction1<T>> selector)

Computes the average of a sequence of int values that is obtained by invoking a projection function on each element of the input sequence.

averageNullableInteger

Integer averageNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)

Computes the average of a sequence of nullable int values that is obtained by invoking a projection function on each element of the input sequence.

averageFloat

float averageFloat(FunctionExpression<FloatFunction1<T>> selector)

Computes the average of a sequence of Float values that is obtained by invoking a projection function on each element of the input sequence.

averageNullableFloat

Float averageNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)

Computes the average of a sequence of nullable Float values that is obtained by invoking a projection function on each element of the input sequence.

averageLong

long averageLong(FunctionExpression<LongFunction1<T>> selector)

Computes the average of a sequence of long values that is obtained by invoking a projection function on each element of the input sequence.

averageNullableLong

Long averageNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)

Computes the average of a sequence of nullable long values that is obtained by invoking a projection function on each element of the input sequence.

concat

Queryable<T> concat(Enumerable<T> source2)

Concatenates two sequences.

Specified by:

concat in interface ExtendedEnumerable<TSource>

count

int count(FunctionExpression<Predicate1<T>> predicate)

Returns the number of elements in the specified sequence that satisfies a condition.

defaultIfEmpty

Queryable<T> defaultIfEmpty()

Returns the elements of the specified sequence or the type parameter's default value in a singleton collection if the sequence is empty.

Specified by:

defaultIfEmpty in interface ExtendedEnumerable<TSource>

distinct

Queryable<T> distinct()

Returns distinct elements from a sequence by using the default equality comparer to compare values.

Specified by:

distinct in interface ExtendedEnumerable<TSource>

distinct

Queryable<T> distinct(EqualityComparer<T> comparer)

Returns distinct elements from a sequence by using a specified EqualityComparer<TSource> to compare values.

Specified by:

distinct in interface ExtendedEnumerable<TSource>

except

Queryable<T> except(Enumerable<T> enumerable)

Produces the set difference of two sequences by using the default equality comparer to compare values, eliminate duplicates. (Defined by Enumerable.)

Specified by:

except in interface ExtendedEnumerable<TSource>

except

Queryable<T> except(Enumerable<T> enumerable,
 boolean all)

Produces the set difference of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates. (Defined by Enumerable.)

Specified by:

except in interface ExtendedEnumerable<TSource>

except

Queryable<T> except(Enumerable<T> enumerable,
 EqualityComparer<T> comparer)

Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.

Specified by:

except in interface ExtendedEnumerable<TSource>

except

Queryable<T> except(Enumerable<T> enumerable,
 EqualityComparer<T> comparer,
 boolean all)

Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.

Specified by:

except in interface ExtendedEnumerable<TSource>

first

T first(FunctionExpression<Predicate1<T>> predicate)

Returns the first element of a sequence that satisfies a specified condition.

firstOrDefault

T firstOrDefault(FunctionExpression<Predicate1<T>> predicate)

Returns the first element of a sequence that satisfies a specified condition or a default value if no such element is found.

groupBy

<TKey> Queryable<Grouping<TKey,T>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector)

Groups the elements of a sequence according to a specified key selector function.

groupBy

<TKey> Queryable<Grouping<TKey,T>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 EqualityComparer<TKey> comparer)

Groups the elements of a sequence according to a specified key selector function and compares the keys by using a specified comparer.

groupBy

<TKey,
TElement> Queryable<Grouping<TKey,TElement>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector)

Groups the elements of a sequence according to a specified key selector function and projects the elements for each group by using a specified function.

groupBy

<TKey,
TElement> Queryable<Grouping<TKey,TElement>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector,
 EqualityComparer<TKey> comparer)

Groups the elements of a sequence and projects the elements for each group by using a specified function. Key values are compared by using a specified comparer.

groupByK

<TKey,
TResult> Queryable<TResult> groupByK(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector)

Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key.

NOTE: Renamed from groupBy to distinguish from groupBy(org.apache.calcite.linq4j.tree.FunctionExpression, org.apache.calcite.linq4j.tree.FunctionExpression), which has the same erasure.

groupByK

<TKey,
TResult> Queryable<TResult> groupByK(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key. Keys are compared by using a specified comparer.

groupBy

<TKey,
TElement,
TResult> Queryable<TResult> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector,
 FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector)

Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key. The elements of each group are projected by using a specified function.

groupBy

<TKey,
TElement,
TResult> Queryable<TResult> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector,
 FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

Groups the elements of a sequence according to a specified key selector function and creates a result value from each group and its key. Keys are compared by using a specified comparer and the elements of each group are projected by using a specified function.

groupJoin

<TInner,
TKey,
TResult> Queryable<TResult> groupJoin(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector)

Correlates the elements of two sequences based on key equality and groups the results. The default equality comparer is used to compare keys.

groupJoin

<TInner,
TKey,
TResult> Queryable<TResult> groupJoin(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

Correlates the elements of two sequences based on key equality and groups the results. A specified EqualityComparer<TSource> is used to compare keys.

intersect

Queryable<T> intersect(Enumerable<T> enumerable)

Produces the set intersection of two sequences by using the default equality comparer to compare values, eliminate duplicates.(Defined by Queryable.)

Specified by:

intersect in interface ExtendedEnumerable<TSource>

intersect

Queryable<T> intersect(Enumerable<T> enumerable,
 boolean all)

Produces the set intersection of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates. (Defined by Queryable.)

Specified by:

intersect in interface ExtendedEnumerable<TSource>

intersect

Queryable<T> intersect(Enumerable<T> enumerable,
 EqualityComparer<T> comparer)

Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.

Specified by:

intersect in interface ExtendedEnumerable<TSource>

intersect

Queryable<T> intersect(Enumerable<T> enumerable,
 EqualityComparer<T> comparer,
 boolean all)

Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.

Specified by:

intersect in interface ExtendedEnumerable<TSource>

join

<TInner,
TKey,
TResult> Queryable<TResult> join(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,TInner,TResult>> resultSelector)

Correlates the elements of two sequences based on matching keys. The default equality comparer is used to compare keys.

join

<TInner,
TKey,
TResult> Queryable<TResult> join(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,TInner,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

Correlates the elements of two sequences based on matching keys. A specified EqualityComparer<TSource> is used to compare keys.

last

T last(FunctionExpression<Predicate1<T>> predicate)

Returns the last element of a sequence that satisfies a specified condition.

lastOrDefault

T lastOrDefault(FunctionExpression<Predicate1<T>> predicate)

Returns the last element of a sequence that satisfies a condition or a default value if no such element is found.

longCount

long longCount(FunctionExpression<Predicate1<T>> predicate)

Returns an long that represents the number of elements in a sequence that satisfy a condition.

max

<TResult extends Comparable<TResult>>
@Nullable TResult max(FunctionExpression<Function1<T,TResult>> selector)

Invokes a projection function on each element of a generic IQueryable<TSource> and returns the maximum resulting value.

min

<TResult extends Comparable<TResult>>
@Nullable TResult min(FunctionExpression<Function1<T,TResult>> selector)

Invokes a projection function on each element of a generic IQueryable<TSource> and returns the minimum resulting value.

ofType

<TResult> Queryable<TResult> ofType(Class<TResult> clazz)

Filters the elements of an IQueryable based on a specified type.

The OfType method generates a MethodCallExpression that represents calling OfType itself as a constructed generic method. It then passes the MethodCallExpression to the CreateQuery(Expression) method of the QueryProvider represented by the Provider property of the source parameter.

The query behavior that occurs as a result of executing an expression tree that represents calling OfType depends on the implementation of the type of the source parameter. The expected behavior is that it filters out any elements in source that are not of type TResult.

NOTE: clazz parameter not present in C# LINQ; necessary because of Java type erasure.

Specified by:

ofType in interface ExtendedEnumerable<TSource>

Type Parameters:

TResult - Target type

Parameters:

clazz - Target type

Returns:

Collection of T2

cast

<T2> Queryable<T2> cast(Class<T2> clazz)

Description copied from interface: ExtendedEnumerable

Converts the elements of this Enumerable to the specified type.

This method is implemented by using deferred execution. The immediate return value is an object that stores all the information that is required to perform the action. The query represented by this method is not executed until the object is enumerated either by calling its RawEnumerable.enumerator() method directly or by using for (... in ...).

If an element cannot be cast to type TResult, the Enumerator.current() method will throw a ClassCastException a exception when the element it accessed. To obtain only those elements that can be cast to type TResult, use the ExtendedEnumerable.ofType(Class) method instead.

Specified by:

cast in interface ExtendedEnumerable<TSource>

See Also:

• EnumerableDefaults.cast(org.apache.calcite.linq4j.Enumerable<TSource>, java.lang.Class<T2>)
• ExtendedEnumerable.ofType(Class)

orderBy

<TKey extends Comparable> OrderedQueryable<T> orderBy(FunctionExpression<Function1<T,TKey>> keySelector)

Sorts the elements of a sequence in ascending order according to a key.

orderBy

<TKey> OrderedQueryable<T> orderBy(FunctionExpression<Function1<T,TKey>> keySelector,
 Comparator<TKey> comparator)

Sorts the elements of a sequence in ascending order by using a specified comparer.

orderByDescending

<TKey extends Comparable> OrderedQueryable<T> orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector)

Sorts the elements of a sequence in descending order according to a key.

orderByDescending

<TKey> OrderedQueryable<T> orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector,
 Comparator<TKey> comparator)

Sorts the elements of a sequence in descending order by using a specified comparer.

reverse

Queryable<T> reverse()

Inverts the order of the elements in a sequence.

Specified by:

reverse in interface ExtendedEnumerable<TSource>

select

<TResult> Queryable<TResult> select(FunctionExpression<Function1<T,TResult>> selector)

Projects each element of a sequence into a new form.

selectN

<TResult> Queryable<TResult> selectN(FunctionExpression<Function2<T,Integer,TResult>> selector)

Projects each element of a sequence into a new form by incorporating the element's index.

NOTE: Renamed from select because had same erasure as select(org.apache.calcite.linq4j.tree.FunctionExpression).

selectMany

<TResult> Queryable<TResult> selectMany(FunctionExpression<Function1<T,Enumerable<TResult>>> selector)

Projects each element of a sequence to an Enumerable<TSource> and combines the resulting sequences into one sequence.

selectManyN

<TResult> Queryable<TResult> selectManyN(FunctionExpression<Function2<T,Integer,Enumerable<TResult>>> selector)

Projects each element of a sequence to an Enumerable<TSource> and combines the resulting sequences into one sequence. The index of each source element is used in the projected form of that element.

NOTE: Renamed from selectMany because had same erasure as selectMany(org.apache.calcite.linq4j.tree.FunctionExpression).

selectMany

<TCollection,
TResult> Queryable<TResult> selectMany(FunctionExpression<Function2<T,Integer,Enumerable<TCollection>>> collectionSelector,
 FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)

Projects each element of a sequence to an Enumerable<TSource> that incorporates the index of the source element that produced it. A result selector function is invoked on each element of each intermediate sequence, and the resulting values are combined into a single, one-dimensional sequence and returned.

selectManyN

<TCollection,
TResult> Queryable<TResult> selectManyN(FunctionExpression<Function1<T,Enumerable<TCollection>>> collectionSelector,
 FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)

Projects each element of a sequence to an Enumerable<TSource> and invokes a result selector function on each element therein. The resulting values from each intermediate sequence are combined into a single, one-dimensional sequence and returned.

NOTE: Renamed from selectMany because had same erasure as selectMany(org.apache.calcite.linq4j.tree.FunctionExpression, org.apache.calcite.linq4j.tree.FunctionExpression)

single

T single(FunctionExpression<Predicate1<T>> predicate)

Returns the only element of a sequence that satisfies a specified condition, and throws an exception if more than one such element exists.

singleOrDefault

T singleOrDefault()

Returns the only element of a sequence, or a default value if the sequence is empty; this method throws an exception if there is more than one element in the sequence.

Specified by:

singleOrDefault in interface ExtendedEnumerable<TSource>

singleOrDefault

T singleOrDefault(FunctionExpression<Predicate1<T>> predicate)

Returns the only element of a sequence that satisfies a specified condition or a default value if no such element exists; this method throws an exception if more than one element satisfies the condition.

skip

Queryable<T> skip(int count)

Bypasses a specified number of elements in a sequence and then returns the remaining elements.

Specified by:

skip in interface ExtendedEnumerable<TSource>

skipWhile

Queryable<T> skipWhile(FunctionExpression<Predicate1<T>> predicate)

Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements.

skipWhileN

Queryable<T> skipWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)

Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements. The element's index is used in the logic of the predicate function.

sumBigDecimal

BigDecimal sumBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)

Computes the sum of the sequence of Decimal values that is obtained by invoking a projection function on each element of the input sequence.

sumNullableBigDecimal

BigDecimal sumNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)

Computes the sum of the sequence of nullable Decimal values that is obtained by invoking a projection function on each element of the input sequence.

sumDouble

double sumDouble(FunctionExpression<DoubleFunction1<T>> selector)

Computes the sum of the sequence of Double values that is obtained by invoking a projection function on each element of the input sequence.

sumNullableDouble

Double sumNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)

Computes the sum of the sequence of nullable Double values that is obtained by invoking a projection function on each element of the input sequence.

sumInteger

int sumInteger(FunctionExpression<IntegerFunction1<T>> selector)

Computes the sum of the sequence of int values that is obtained by invoking a projection function on each element of the input sequence.

sumNullableInteger

Integer sumNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)

Computes the sum of the sequence of nullable int values that is obtained by invoking a projection function on each element of the input sequence.

sumLong

long sumLong(FunctionExpression<LongFunction1<T>> selector)

Computes the sum of the sequence of long values that is obtained by invoking a projection function on each element of the input sequence.

sumNullableLong

Long sumNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)

Computes the sum of the sequence of nullable long values that is obtained by invoking a projection function on each element of the input sequence.

sumFloat

float sumFloat(FunctionExpression<FloatFunction1<T>> selector)

Computes the sum of the sequence of Float values that is obtained by invoking a projection function on each element of the input sequence.

sumNullableFloat

Float sumNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)

Computes the sum of the sequence of nullable Float values that is obtained by invoking a projection function on each element of the input sequence.

take

Queryable<T> take(int count)

Returns a specified number of contiguous elements from the start of a sequence.

Specified by:

take in interface ExtendedEnumerable<TSource>

takeWhile

Queryable<T> takeWhile(FunctionExpression<Predicate1<T>> predicate)

Returns elements from a sequence as long as a specified condition is true.

takeWhileN

Queryable<T> takeWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)

Returns elements from a sequence as long as a specified condition is true. The element's index is used in the logic of the predicate function.

union

Queryable<T> union(Enumerable<T> source1)

Produces the set union of two sequences by using the default equality comparer.

Specified by:

union in interface ExtendedEnumerable<TSource>

union

Queryable<T> union(Enumerable<T> source1,
 EqualityComparer<T> comparer)

Produces the set union of two sequences by using a specified EqualityComparer<TSource>.

Specified by:

union in interface ExtendedEnumerable<TSource>

where

Queryable<T> where(FunctionExpression<? extends Predicate1<T>> predicate)

Filters a sequence of values based on a predicate.

whereN

Queryable<T> whereN(FunctionExpression<? extends Predicate2<T,Integer>> predicate)

Filters a sequence of values based on a predicate. Each element's index is used in the logic of the predicate function.

zip

<T1,
TResult> Queryable<TResult> zip(Enumerable<T1> source1,
 FunctionExpression<Function2<T,T1,TResult>> resultSelector)

Merges two sequences by using the specified predicate function.

getThis

protected Queryable<T> getThis()

Description copied from class: DefaultEnumerable

Derived classes might wish to override this method to return the "outer" enumerable.

Overrides:

getThis in class DefaultEnumerable<T>

getThisOrderedQueryable

protected OrderedQueryable<T> getThisOrderedQueryable()

asEnumerable

public Enumerable<T> asEnumerable()

Description copied from interface: ExtendedEnumerable

Returns the input typed as Enumerable<TSource>.

This method has no effect other than to change the compile-time type of source from a type that implements Enumerable<TSource> to Enumerable<TSource> itself.

asEnumerable<TSource>(Enumerable<TSource>) can be used to choose between query implementations when a sequence implements Enumerable<TSource> but also has a different set of public query methods available. For example, given a generic class Table that implements Enumerable<TSource> and has its own methods such as where, select, and selectMany, a call to where would invoke the public where method of Table. A Table type that represents a database table could have a where method that takes the predicate argument as an expression tree and converts the tree to SQL for remote execution. If remote execution is not desired, for example because the predicate invokes a local method, the asEnumerable<TSource> method can be used to hide the custom methods and instead make the standard query operators available.

Specified by:

asEnumerable in interface ExtendedEnumerable<T>

Overrides:

asEnumerable in class DefaultEnumerable<T>

union

public Queryable<T> union(Enumerable<T> source1)

Description copied from interface: ExtendedEnumerable

Produces the set union of two sequences by using the default equality comparer.

Specified by:

union in interface ExtendedEnumerable<T>

Overrides:

union in class DefaultEnumerable<T>

union

public Queryable<T> union(Enumerable<T> source1,
 EqualityComparer<T> comparer)

Description copied from interface: ExtendedEnumerable

Produces the set union of two sequences by using a specified EqualityComparer<TSource>.

Specified by:

union in interface ExtendedEnumerable<T>

Overrides:

union in class DefaultEnumerable<T>

intersect

public Queryable<T> intersect(Enumerable<T> source1)

Description copied from interface: ExtendedEnumerable

Produces the set intersection of two sequences by using the default equality comparer to compare values, eliminate duplicates. (Defined by Enumerable.)

Specified by:

intersect in interface ExtendedEnumerable<T>

Overrides:

intersect in class DefaultEnumerable<T>

intersect

public Queryable<T> intersect(Enumerable<T> source1,
 boolean all)

Description copied from interface: ExtendedEnumerable

Produces the set intersection of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates. (Defined by Enumerable.)

Specified by:

intersect in interface ExtendedEnumerable<T>

Overrides:

intersect in class DefaultEnumerable<T>

intersect

public Queryable<T> intersect(Enumerable<T> source1,
 EqualityComparer<T> comparer)

Description copied from interface: ExtendedEnumerable

Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.

Specified by:

intersect in interface ExtendedEnumerable<T>

Overrides:

intersect in class DefaultEnumerable<T>

intersect

public Queryable<T> intersect(Enumerable<T> source1,
 EqualityComparer<T> comparer,
 boolean all)

Description copied from interface: ExtendedEnumerable

Produces the set intersection of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.

Specified by:

intersect in interface ExtendedEnumerable<T>

Overrides:

intersect in class DefaultEnumerable<T>

except

public Queryable<T> except(Enumerable<T> enumerable1,
 EqualityComparer<T> comparer)

Description copied from interface: ExtendedEnumerable

Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, eliminate duplicates.

Specified by:

except in interface ExtendedEnumerable<T>

Overrides:

except in class DefaultEnumerable<T>

except

public Queryable<T> except(Enumerable<T> enumerable1,
 EqualityComparer<T> comparer,
 boolean all)

Description copied from interface: ExtendedEnumerable

Produces the set difference of two sequences by using the specified EqualityComparer<TSource> to compare values, using all to indicate whether to eliminate duplicates.

Specified by:

except in interface ExtendedEnumerable<T>

Overrides:

except in class DefaultEnumerable<T>

except

public Queryable<T> except(Enumerable<T> enumerable1)

Description copied from interface: ExtendedEnumerable

Produces the set difference of two sequences by using the default equality comparer to compare values, eliminate duplicates. (Defined by Enumerable.)

Specified by:

except in interface ExtendedEnumerable<T>

Overrides:

except in class DefaultEnumerable<T>

except

public Queryable<T> except(Enumerable<T> enumerable1,
 boolean all)

Description copied from interface: ExtendedEnumerable

Produces the set difference of two sequences by using the default equality comparer to compare values, using all to indicate whether to eliminate duplicates. (Defined by Enumerable.)

Specified by:

except in interface ExtendedEnumerable<T>

Overrides:

except in class DefaultEnumerable<T>

take

public Queryable<T> take(int count)

Description copied from interface: ExtendedEnumerable

Returns a specified number of contiguous elements from the start of a sequence.

Specified by:

take in interface ExtendedEnumerable<T>

Overrides:

take in class DefaultEnumerable<T>

skip

public Queryable<T> skip(int count)

Description copied from interface: ExtendedEnumerable

Bypasses a specified number of elements in a sequence and then returns the remaining elements.

Specified by:

skip in interface ExtendedEnumerable<T>

Overrides:

skip in class DefaultEnumerable<T>

reverse

public Queryable<T> reverse()

Description copied from interface: ExtendedEnumerable

Inverts the order of the elements in a sequence.

Specified by:

reverse in interface ExtendedEnumerable<T>

Overrides:

reverse in class DefaultEnumerable<T>

distinct

public Queryable<T> distinct()

Description copied from interface: ExtendedEnumerable

Returns distinct elements from a sequence by using the default equality comparer to compare values.

Specified by:

distinct in interface ExtendedEnumerable<T>

Overrides:

distinct in class DefaultEnumerable<T>

distinct

public Queryable<T> distinct(EqualityComparer<T> comparer)

Description copied from interface: ExtendedEnumerable

Returns distinct elements from a sequence by using a specified EqualityComparer<TSource> to compare values.

Specified by:

distinct in interface ExtendedEnumerable<T>

Overrides:

distinct in class DefaultEnumerable<T>

ofType

public <TResult> Queryable<TResult> ofType(Class<TResult> clazz)

Description copied from interface: ExtendedEnumerable

Filters the elements of an Enumerable based on a specified type.

Analogous to LINQ's Enumerable.OfType extension method.

Specified by:

ofType in interface ExtendedEnumerable<T>

Overrides:

ofType in class DefaultEnumerable<T>

Type Parameters:

TResult - Target type

Parameters:

clazz - Target type

Returns:

Collection of T2

defaultIfEmpty

public Queryable<T> defaultIfEmpty()

Description copied from interface: ExtendedEnumerable

Returns the elements of the specified sequence or the type parameter's default value in a singleton collection if the sequence is empty.

Specified by:

defaultIfEmpty in interface ExtendedEnumerable<T>

Overrides:

defaultIfEmpty in class DefaultEnumerable<T>

asQueryable

public Queryable<T> asQueryable()

Description copied from interface: Enumerable

Converts this Enumerable to a Queryable.

Specified by:

asQueryable in interface Enumerable<T>

Specified by:

asQueryable in interface ExtendedEnumerable<T>

Overrides:

asQueryable in class DefaultEnumerable<T>

Returns:

A queryable

See Also:

• EnumerableDefaults.asQueryable(Enumerable)

cast

public <T2> Queryable<T2> cast(Class<T2> clazz)

Description copied from interface: ExtendedEnumerable

Converts the elements of this Enumerable to the specified type.

This method is implemented by using deferred execution. The immediate return value is an object that stores all the information that is required to perform the action. The query represented by this method is not executed until the object is enumerated either by calling its RawEnumerable.enumerator() method directly or by using for (... in ...).

If an element cannot be cast to type TResult, the Enumerator.current() method will throw a ClassCastException a exception when the element it accessed. To obtain only those elements that can be cast to type TResult, use the ExtendedEnumerable.ofType(Class) method instead.

Specified by:

cast in interface ExtendedEnumerable<T>

Overrides:

cast in class DefaultEnumerable<T>

See Also:

• EnumerableDefaults.cast(org.apache.calcite.linq4j.Enumerable<TSource>, java.lang.Class<T2>)
• ExtendedEnumerable.ofType(Class)

aggregate

public T aggregate(FunctionExpression<Function2<T,T,T>> selector)

aggregate

public <TAccumulate> TAccumulate aggregate(TAccumulate seed,
 FunctionExpression<Function2<TAccumulate,T,TAccumulate>> selector)

aggregate

public <TAccumulate,
TResult> TResult aggregate(TAccumulate seed,
 FunctionExpression<Function2<TAccumulate,T,TAccumulate>> func,
 FunctionExpression<Function1<TAccumulate,TResult>> selector)

all

public boolean all(FunctionExpression<Predicate1<T>> predicate)

any

public boolean any(FunctionExpression<Predicate1<T>> predicate)

averageBigDecimal

public BigDecimal averageBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)

averageNullableBigDecimal

public BigDecimal averageNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)

averageDouble

public double averageDouble(FunctionExpression<DoubleFunction1<T>> selector)

averageNullableDouble

public Double averageNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)

averageInteger

public int averageInteger(FunctionExpression<IntegerFunction1<T>> selector)

averageNullableInteger

public Integer averageNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)

averageFloat

public float averageFloat(FunctionExpression<FloatFunction1<T>> selector)

averageNullableFloat

public Float averageNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)

averageLong

public long averageLong(FunctionExpression<LongFunction1<T>> selector)

averageNullableLong

public Long averageNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)

concat

public Queryable<T> concat(Enumerable<T> source2)

Description copied from interface: ExtendedEnumerable

Concatenates two sequences.

Specified by:

concat in interface ExtendedEnumerable<T>

Overrides:

concat in class DefaultEnumerable<T>

count

public int count(FunctionExpression<Predicate1<T>> func)

first

public T first(FunctionExpression<Predicate1<T>> predicate)

firstOrDefault

public T firstOrDefault(FunctionExpression<Predicate1<T>> predicate)

groupBy

public <TKey> Queryable<Grouping<TKey,T>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector)

groupBy

public <TKey> Queryable<Grouping<TKey,T>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 EqualityComparer<TKey> comparer)

groupBy

public <TKey,
TElement>
Queryable<Grouping<TKey,TElement>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector)

groupBy

public <TKey,
TElement>
Queryable<Grouping<TKey,TElement>> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector,
 EqualityComparer<TKey> comparer)

groupByK

public <TKey,
TResult> Queryable<TResult> groupByK(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector)

groupByK

public <TKey,
TResult> Queryable<TResult> groupByK(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function2<TKey,Enumerable<T>,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

groupBy

public <TKey,
TElement,
TResult> Queryable<TResult> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector,
 FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector)

groupBy

public <TKey,
TElement,
TResult> Queryable<TResult> groupBy(FunctionExpression<Function1<T,TKey>> keySelector,
 FunctionExpression<Function1<T,TElement>> elementSelector,
 FunctionExpression<Function2<TKey,Enumerable<TElement>,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

groupJoin

public <TInner,
TKey,
TResult> Queryable<TResult> groupJoin(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector)

groupJoin

public <TInner,
TKey,
TResult> Queryable<TResult> groupJoin(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,Enumerable<TInner>,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

join

public <TInner,
TKey,
TResult> Queryable<TResult> join(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,TInner,TResult>> resultSelector)

join

public <TInner,
TKey,
TResult> Queryable<TResult> join(Enumerable<TInner> inner,
 FunctionExpression<Function1<T,TKey>> outerKeySelector,
 FunctionExpression<Function1<TInner,TKey>> innerKeySelector,
 FunctionExpression<Function2<T,TInner,TResult>> resultSelector,
 EqualityComparer<TKey> comparer)

last

public T last(FunctionExpression<Predicate1<T>> predicate)

lastOrDefault

public T lastOrDefault(FunctionExpression<Predicate1<T>> predicate)

longCount

public long longCount(FunctionExpression<Predicate1<T>> predicate)

max

public <TResult extends Comparable<TResult>>
TResult max(FunctionExpression<Function1<T,TResult>> selector)

min

public <TResult extends Comparable<TResult>>
TResult min(FunctionExpression<Function1<T,TResult>> selector)

orderBy

public <TKey extends Comparable>
OrderedQueryable<T> orderBy(FunctionExpression<Function1<T,TKey>> keySelector)

orderBy

public <TKey> OrderedQueryable<T> orderBy(FunctionExpression<Function1<T,TKey>> keySelector,
 Comparator<TKey> comparator)

orderByDescending

public <TKey extends Comparable>
OrderedQueryable<T> orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector)

orderByDescending

public <TKey> OrderedQueryable<T> orderByDescending(FunctionExpression<Function1<T,TKey>> keySelector,
 Comparator<TKey> comparator)

select

public <TResult> Queryable<TResult> select(FunctionExpression<Function1<T,TResult>> selector)

selectN

public <TResult> Queryable<TResult> selectN(FunctionExpression<Function2<T,Integer,TResult>> selector)

selectMany

public <TResult> Queryable<TResult> selectMany(FunctionExpression<Function1<T,Enumerable<TResult>>> selector)

selectManyN

public <TResult> Queryable<TResult> selectManyN(FunctionExpression<Function2<T,Integer,Enumerable<TResult>>> selector)

selectMany

public <TCollection,
TResult> Queryable<TResult> selectMany(FunctionExpression<Function2<T,Integer,Enumerable<TCollection>>> collectionSelector,
 FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)

selectManyN

public <TCollection,
TResult> Queryable<TResult> selectManyN(FunctionExpression<Function1<T,Enumerable<TCollection>>> collectionSelector,
 FunctionExpression<Function2<T,TCollection,TResult>> resultSelector)

single

public T single(FunctionExpression<Predicate1<T>> predicate)

singleOrDefault

public T singleOrDefault(FunctionExpression<Predicate1<T>> predicate)

skipWhile

public Queryable<T> skipWhile(FunctionExpression<Predicate1<T>> predicate)

skipWhileN

public Queryable<T> skipWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)

sumBigDecimal

public BigDecimal sumBigDecimal(FunctionExpression<BigDecimalFunction1<T>> selector)

sumNullableBigDecimal

public BigDecimal sumNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<T>> selector)

sumDouble

public double sumDouble(FunctionExpression<DoubleFunction1<T>> selector)

sumNullableDouble

public Double sumNullableDouble(FunctionExpression<NullableDoubleFunction1<T>> selector)

sumInteger

public int sumInteger(FunctionExpression<IntegerFunction1<T>> selector)

sumNullableInteger

public Integer sumNullableInteger(FunctionExpression<NullableIntegerFunction1<T>> selector)

sumLong

public long sumLong(FunctionExpression<LongFunction1<T>> selector)

sumNullableLong

public Long sumNullableLong(FunctionExpression<NullableLongFunction1<T>> selector)

sumFloat

public float sumFloat(FunctionExpression<FloatFunction1<T>> selector)

sumNullableFloat

public Float sumNullableFloat(FunctionExpression<NullableFloatFunction1<T>> selector)

takeWhile

public Queryable<T> takeWhile(FunctionExpression<Predicate1<T>> predicate)

takeWhileN

public Queryable<T> takeWhileN(FunctionExpression<Predicate2<T,Integer>> predicate)

thenBy

public <TKey extends Comparable<TKey>>
OrderedQueryable<T> thenBy(FunctionExpression<Function1<T,TKey>> keySelector)

Description copied from interface: ExtendedOrderedQueryable

Performs a subsequent ordering of the elements in a sequence in ascending order according to a key.

Specified by:

thenBy in interface ExtendedOrderedQueryable<T>

thenBy

public <TKey> OrderedQueryable<T> thenBy(FunctionExpression<Function1<T,TKey>> keySelector,
 Comparator<TKey> comparator)

Description copied from interface: ExtendedOrderedQueryable

Performs a subsequent ordering of the elements in a sequence in ascending order according to a key, using a specified comparator.

Specified by:

thenBy in interface ExtendedOrderedQueryable<T>

thenByDescending

public <TKey extends Comparable<TKey>>
OrderedQueryable<T> thenByDescending(FunctionExpression<Function1<T,TKey>> keySelector)

Description copied from interface: ExtendedOrderedQueryable

Performs a subsequent ordering of the elements in a sequence in descending order according to a key.

Specified by:

thenByDescending in interface ExtendedOrderedQueryable<T>

thenByDescending

public <TKey> OrderedQueryable<T> thenByDescending(FunctionExpression<Function1<T,TKey>> keySelector,
 Comparator<TKey> comparator)

Description copied from interface: ExtendedOrderedQueryable

Performs a subsequent ordering of the elements in a sequence in descending order according to a key, using a specified comparator.

Specified by:

thenByDescending in interface ExtendedOrderedQueryable<T>

where

public Queryable<T> where(FunctionExpression<? extends Predicate1<T>> predicate)

whereN

public Queryable<T> whereN(FunctionExpression<? extends Predicate2<T,Integer>> predicate)

zip

public <T1,
TResult> Queryable<TResult> zip(Enumerable<T1> source1,
 FunctionExpression<Function2<T,T1,TResult>> resultSelector)