Interface ExtendedQueryable<TSource>
-
- Type Parameters:
TSource
- Element type
- All Superinterfaces:
ExtendedEnumerable<TSource>
- All Known Subinterfaces:
ExtendedOrderedQueryable<T>
,OrderedQueryable<T>
,Queryable<T>
,QueryableDefaults.Replayable<T>
- All Known Implementing Classes:
AbstractQueryable
,AbstractTableQueryable
,BaseQueryable
,CalciteConnectionImpl.CalciteQueryable
,CassandraTable.CassandraQueryable
,DefaultQueryable
,ElasticsearchTable.ElasticsearchQueryable
,EnumerableOrderedQueryable
,EnumerableQueryable
,GeodeTable.GeodeQueryable
,JdbcTable.JdbcTableQueryable
,MongoTable.MongoQueryable
,QueryableDefaults.NonLeafReplayableQueryable
,QueryableDefaults.ReplayableQueryable
,QueryProviderImpl.QueryableImpl
,SplunkTable.SplunkTableQueryable
interface ExtendedQueryable<TSource> extends ExtendedEnumerable<TSource>
Extension methods in Queryable.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description TSource
aggregate(FunctionExpression<Function2<TSource,TSource,TSource>> selector)
Applies an accumulator function over a sequence.<TAccumulate>
TAccumulateaggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,TSource,TAccumulate>> selector)
Applies an accumulator function over a sequence.<TAccumulate,TResult>
TResultaggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,TSource,TAccumulate>> func, FunctionExpression<Function1<TAccumulate,TResult>> selector)
Applies an accumulator function over a sequence.boolean
all(FunctionExpression<Predicate1<TSource>> predicate)
Determines whether all the elements of a sequence satisfy a condition.boolean
any(FunctionExpression<Predicate1<TSource>> predicate)
Determines whether any element of a sequence satisfies a condition.java.math.BigDecimal
averageBigDecimal(FunctionExpression<BigDecimalFunction1<TSource>> 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<TSource>> 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<TSource>> 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<TSource>> 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<TSource>> 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.java.math.BigDecimal
averageNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<TSource>> 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.java.lang.Double
averageNullableDouble(FunctionExpression<NullableDoubleFunction1<TSource>> 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.java.lang.Float
averageNullableFloat(FunctionExpression<NullableFloatFunction1<TSource>> 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.java.lang.Integer
averageNullableInteger(FunctionExpression<NullableIntegerFunction1<TSource>> 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.java.lang.Long
averageNullableLong(FunctionExpression<NullableLongFunction1<TSource>> 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(java.lang.Class<T2> clazz)
Converts the elements of this Enumerable to the specified type.Queryable<TSource>
concat(Enumerable<TSource> source2)
Concatenates two sequences.int
count(FunctionExpression<Predicate1<TSource>> predicate)
Returns the number of elements in the specified sequence that satisfies a condition.Queryable<TSource>
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<TSource>
distinct()
Returns distinct elements from a sequence by using the default equality comparer to compare values.Queryable<TSource>
distinct(EqualityComparer<TSource> comparer)
Returns distinct elements from a sequence by using a specified EqualityComparer<TSource> to compare values.Queryable<TSource>
except(Enumerable<TSource> enumerable)
Produces the set difference of two sequences by using the default equality comparer to compare values.Queryable<TSource>
except(Enumerable<TSource> enumerable, EqualityComparer<TSource> comparer)
Produces the set difference of two sequences by using the specifiedEqualityComparer<TSource>
to compare values.TSource
first(FunctionExpression<Predicate1<TSource>> predicate)
Returns the first element of a sequence that satisfies a specified condition.TSource
firstOrDefault(FunctionExpression<Predicate1<TSource>> predicate)
Returns the first element of a sequence that satisfies a specified condition or a default value if no such element is found.<TKey> Queryable<Grouping<TKey,TSource>>
groupBy(FunctionExpression<Function1<TSource,TKey>> keySelector)
Groups the elements of a sequence according to a specified key selector function.<TKey> Queryable<Grouping<TKey,TSource>>
groupBy(FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<TSource>,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<TSource,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<TSource>,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<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,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<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,Enumerable<TInner>,TResult>> resultSelector, EqualityComparer<TKey> comparer)
Correlates the elements of two sequences based on key equality and groups the results.Queryable<TSource>
intersect(Enumerable<TSource> enumerable)
Produces the set intersection of two sequences by using the default equality comparer to compare values.Queryable<TSource>
intersect(Enumerable<TSource> enumerable, EqualityComparer<TSource> comparer)
Produces the set intersection of two sequences by using the specifiedEqualityComparer<TSource>
to compare values.<TInner,TKey,TResult>
Queryable<TResult>join(Enumerable<TInner> inner, FunctionExpression<Function1<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,TInner,TResult>> resultSelector)
Correlates the elements of two sequences based on matching keys.<TInner,TKey,TResult>
Queryable<TResult>join(Enumerable<TInner> inner, FunctionExpression<Function1<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,TInner,TResult>> resultSelector, EqualityComparer<TKey> comparer)
Correlates the elements of two sequences based on matching keys.TSource
last(FunctionExpression<Predicate1<TSource>> predicate)
Returns the last element of a sequence that satisfies a specified condition.TSource
lastOrDefault(FunctionExpression<Predicate1<TSource>> 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<TSource>> predicate)
Returns an long that represents the number of elements in a sequence that satisfy a condition.<TResult extends java.lang.Comparable<TResult>>
TResultmax(FunctionExpression<Function1<TSource,TResult>> selector)
Invokes a projection function on each element of a genericIQueryable<TSource>
and returns the maximum resulting value.<TResult extends java.lang.Comparable<TResult>>
TResultmin(FunctionExpression<Function1<TSource,TResult>> selector)
Invokes a projection function on each element of a genericIQueryable<TSource>
and returns the minimum resulting value.<TResult> Queryable<TResult>
ofType(java.lang.Class<TResult> clazz)
Filters the elements of an IQueryable based on a specified type.<TKey extends java.lang.Comparable>
OrderedQueryable<TSource>orderBy(FunctionExpression<Function1<TSource,TKey>> keySelector)
Sorts the elements of a sequence in ascending order according to a key.<TKey> OrderedQueryable<TSource>
orderBy(FunctionExpression<Function1<TSource,TKey>> keySelector, java.util.Comparator<TKey> comparator)
Sorts the elements of a sequence in ascending order by using a specified comparer.<TKey extends java.lang.Comparable>
OrderedQueryable<TSource>orderByDescending(FunctionExpression<Function1<TSource,TKey>> keySelector)
Sorts the elements of a sequence in descending order according to a key.<TKey> OrderedQueryable<TSource>
orderByDescending(FunctionExpression<Function1<TSource,TKey>> keySelector, java.util.Comparator<TKey> comparator)
Sorts the elements of a sequence in descending order by using a specified comparer.Queryable<TSource>
reverse()
Inverts the order of the elements in a sequence.<TResult> Queryable<TResult>
select(FunctionExpression<Function1<TSource,TResult>> selector)
Projects each element of a sequence into a new form.<TResult> Queryable<TResult>
selectMany(FunctionExpression<Function1<TSource,Enumerable<TResult>>> selector)
Projects each element of a sequence to anEnumerable<TSource>
and combines the resulting sequences into one sequence.<TCollection,TResult>
Queryable<TResult>selectMany(FunctionExpression<Function2<TSource,java.lang.Integer,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<TSource,TCollection,TResult>> resultSelector)
Projects each element of a sequence to anEnumerable<TSource>
that incorporates the index of the source element that produced it.<TCollection,TResult>
Queryable<TResult>selectManyN(FunctionExpression<Function1<TSource,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<TSource,TCollection,TResult>> resultSelector)
Projects each element of a sequence to anEnumerable<TSource>
and invokes a result selector function on each element therein.<TResult> Queryable<TResult>
selectManyN(FunctionExpression<Function2<TSource,java.lang.Integer,Enumerable<TResult>>> selector)
Projects each element of a sequence to anEnumerable<TSource>
and combines the resulting sequences into one sequence.<TResult> Queryable<TResult>
selectN(FunctionExpression<Function2<TSource,java.lang.Integer,TResult>> selector)
Projects each element of a sequence into a new form by incorporating the element's index.TSource
single(FunctionExpression<Predicate1<TSource>> predicate)
Returns the only element of a sequence that satisfies a specified condition, and throws an exception if more than one such element exists.TSource
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.TSource
singleOrDefault(FunctionExpression<Predicate1<TSource>> 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<TSource>
skip(int count)
Bypasses a specified number of elements in a sequence and then returns the remaining elements.Queryable<TSource>
skipWhile(FunctionExpression<Predicate1<TSource>> predicate)
Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements.Queryable<TSource>
skipWhileN(FunctionExpression<Predicate2<TSource,java.lang.Integer>> predicate)
Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements.java.math.BigDecimal
sumBigDecimal(FunctionExpression<BigDecimalFunction1<TSource>> 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<TSource>> 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<TSource>> 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<TSource>> 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<TSource>> 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.java.math.BigDecimal
sumNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<TSource>> 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.java.lang.Double
sumNullableDouble(FunctionExpression<NullableDoubleFunction1<TSource>> 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.java.lang.Float
sumNullableFloat(FunctionExpression<NullableFloatFunction1<TSource>> 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.java.lang.Integer
sumNullableInteger(FunctionExpression<NullableIntegerFunction1<TSource>> 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.java.lang.Long
sumNullableLong(FunctionExpression<NullableLongFunction1<TSource>> 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<TSource>
take(int count)
Returns a specified number of contiguous elements from the start of a sequence.Queryable<TSource>
takeWhile(FunctionExpression<Predicate1<TSource>> predicate)
Returns elements from a sequence as long as a specified condition is true.Queryable<TSource>
takeWhileN(FunctionExpression<Predicate2<TSource,java.lang.Integer>> predicate)
Returns elements from a sequence as long as a specified condition is true.Queryable<TSource>
union(Enumerable<TSource> source1)
Produces the set union of two sequences by using the default equality comparer.Queryable<TSource>
union(Enumerable<TSource> source1, EqualityComparer<TSource> comparer)
Produces the set union of two sequences by using a specifiedEqualityComparer<TSource>
.Queryable<TSource>
where(FunctionExpression<? extends Predicate1<TSource>> predicate)
Filters a sequence of values based on a predicate.Queryable<TSource>
whereN(FunctionExpression<? extends Predicate2<TSource,java.lang.Integer>> predicate)
Filters a sequence of values based on a predicate.<T1,TResult>
Queryable<TResult>zip(Enumerable<T1> source1, FunctionExpression<Function2<TSource,T1,TResult>> resultSelector)
Merges two sequences by using the specified predicate function.-
Methods inherited from interface org.apache.calcite.linq4j.ExtendedEnumerable
aggregate, aggregate, aggregate, all, any, any, asEnumerable, asQueryable, 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, into, join, join, join, 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, sum, sum, sum, sum, sum, sum, sum, sum, sum, sum, takeWhile, takeWhile, toList, toLookup, toLookup, toLookup, toLookup, toMap, toMap, toMap, toMap, where, where, zip
-
-
-
-
Method Detail
-
aggregate
TSource aggregate(FunctionExpression<Function2<TSource,TSource,TSource>> selector)
Applies an accumulator function over a sequence.
-
aggregate
<TAccumulate> TAccumulate aggregate(TAccumulate seed, FunctionExpression<Function2<TAccumulate,TSource,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,TSource,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<TSource>> predicate)
Determines whether all the elements of a sequence satisfy a condition.
-
any
boolean any(FunctionExpression<Predicate1<TSource>> predicate)
Determines whether any element of a sequence satisfies a condition.
-
averageBigDecimal
java.math.BigDecimal averageBigDecimal(FunctionExpression<BigDecimalFunction1<TSource>> 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
java.math.BigDecimal averageNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<TSource>> 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<TSource>> 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
java.lang.Double averageNullableDouble(FunctionExpression<NullableDoubleFunction1<TSource>> 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<TSource>> 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
java.lang.Integer averageNullableInteger(FunctionExpression<NullableIntegerFunction1<TSource>> 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<TSource>> 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
java.lang.Float averageNullableFloat(FunctionExpression<NullableFloatFunction1<TSource>> 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<TSource>> 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
java.lang.Long averageNullableLong(FunctionExpression<NullableLongFunction1<TSource>> 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<TSource> concat(Enumerable<TSource> source2)
Concatenates two sequences.- Specified by:
concat
in interfaceExtendedEnumerable<TSource>
-
count
int count(FunctionExpression<Predicate1<TSource>> predicate)
Returns the number of elements in the specified sequence that satisfies a condition.
-
defaultIfEmpty
Queryable<TSource> 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 interfaceExtendedEnumerable<TSource>
-
distinct
Queryable<TSource> distinct()
Returns distinct elements from a sequence by using the default equality comparer to compare values.- Specified by:
distinct
in interfaceExtendedEnumerable<TSource>
-
distinct
Queryable<TSource> distinct(EqualityComparer<TSource> comparer)
Returns distinct elements from a sequence by using a specified EqualityComparer<TSource> to compare values.- Specified by:
distinct
in interfaceExtendedEnumerable<TSource>
-
except
Queryable<TSource> except(Enumerable<TSource> enumerable)
Produces the set difference of two sequences by using the default equality comparer to compare values. (Defined by Queryable.)- Specified by:
except
in interfaceExtendedEnumerable<TSource>
-
except
Queryable<TSource> except(Enumerable<TSource> enumerable, EqualityComparer<TSource> comparer)
Produces the set difference of two sequences by using the specifiedEqualityComparer<TSource>
to compare values.- Specified by:
except
in interfaceExtendedEnumerable<TSource>
-
first
TSource first(FunctionExpression<Predicate1<TSource>> predicate)
Returns the first element of a sequence that satisfies a specified condition.
-
firstOrDefault
TSource firstOrDefault(FunctionExpression<Predicate1<TSource>> 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,TSource>> groupBy(FunctionExpression<Function1<TSource,TKey>> keySelector)
Groups the elements of a sequence according to a specified key selector function.
-
groupBy
<TKey> Queryable<Grouping<TKey,TSource>> groupBy(FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<TSource>,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 fromgroupBy(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<TSource,TKey>> keySelector, FunctionExpression<Function2<TKey,Enumerable<TSource>,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> keySelector, FunctionExpression<Function1<TSource,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<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,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<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,Enumerable<TInner>,TResult>> resultSelector, EqualityComparer<TKey> comparer)
Correlates the elements of two sequences based on key equality and groups the results. A specifiedEqualityComparer<TSource>
is used to compare keys.
-
intersect
Queryable<TSource> intersect(Enumerable<TSource> enumerable)
Produces the set intersection of two sequences by using the default equality comparer to compare values. (Defined by Queryable.)- Specified by:
intersect
in interfaceExtendedEnumerable<TSource>
-
intersect
Queryable<TSource> intersect(Enumerable<TSource> enumerable, EqualityComparer<TSource> comparer)
Produces the set intersection of two sequences by using the specifiedEqualityComparer<TSource>
to compare values.- Specified by:
intersect
in interfaceExtendedEnumerable<TSource>
-
join
<TInner,TKey,TResult> Queryable<TResult> join(Enumerable<TInner> inner, FunctionExpression<Function1<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,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<TSource,TKey>> outerKeySelector, FunctionExpression<Function1<TInner,TKey>> innerKeySelector, FunctionExpression<Function2<TSource,TInner,TResult>> resultSelector, EqualityComparer<TKey> comparer)
Correlates the elements of two sequences based on matching keys. A specifiedEqualityComparer<TSource>
is used to compare keys.
-
last
TSource last(FunctionExpression<Predicate1<TSource>> predicate)
Returns the last element of a sequence that satisfies a specified condition.
-
lastOrDefault
TSource lastOrDefault(FunctionExpression<Predicate1<TSource>> 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<TSource>> predicate)
Returns an long that represents the number of elements in a sequence that satisfy a condition.
-
max
<TResult extends java.lang.Comparable<TResult>> TResult max(FunctionExpression<Function1<TSource,TResult>> selector)
Invokes a projection function on each element of a genericIQueryable<TSource>
and returns the maximum resulting value.
-
min
<TResult extends java.lang.Comparable<TResult>> TResult min(FunctionExpression<Function1<TSource,TResult>> selector)
Invokes a projection function on each element of a genericIQueryable<TSource>
and returns the minimum resulting value.
-
ofType
<TResult> Queryable<TResult> ofType(java.lang.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 theQueryProvider
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 interfaceExtendedEnumerable<TSource>
- Type Parameters:
TResult
- Target type- Parameters:
clazz
- Target type- Returns:
- Collection of T2
-
cast
<T2> Queryable<T2> cast(java.lang.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 usingfor (... in ...)
.If an element cannot be cast to type TResult, the
Enumerator.current()
method will throw aClassCastException
a exception when the element it accessed. To obtain only those elements that can be cast to type TResult, use theExtendedEnumerable.ofType(Class)
method instead.- Specified by:
cast
in interfaceExtendedEnumerable<TSource>
- See Also:
EnumerableDefaults.cast(org.apache.calcite.linq4j.Enumerable<TSource>, java.lang.Class<T2>)
,ExtendedEnumerable.ofType(Class)
-
orderBy
<TKey extends java.lang.Comparable> OrderedQueryable<TSource> orderBy(FunctionExpression<Function1<TSource,TKey>> keySelector)
Sorts the elements of a sequence in ascending order according to a key.
-
orderBy
<TKey> OrderedQueryable<TSource> orderBy(FunctionExpression<Function1<TSource,TKey>> keySelector, java.util.Comparator<TKey> comparator)
Sorts the elements of a sequence in ascending order by using a specified comparer.
-
orderByDescending
<TKey extends java.lang.Comparable> OrderedQueryable<TSource> orderByDescending(FunctionExpression<Function1<TSource,TKey>> keySelector)
Sorts the elements of a sequence in descending order according to a key.
-
orderByDescending
<TKey> OrderedQueryable<TSource> orderByDescending(FunctionExpression<Function1<TSource,TKey>> keySelector, java.util.Comparator<TKey> comparator)
Sorts the elements of a sequence in descending order by using a specified comparer.
-
reverse
Queryable<TSource> reverse()
Inverts the order of the elements in a sequence.- Specified by:
reverse
in interfaceExtendedEnumerable<TSource>
-
select
<TResult> Queryable<TResult> select(FunctionExpression<Function1<TSource,TResult>> selector)
Projects each element of a sequence into a new form.
-
selectN
<TResult> Queryable<TResult> selectN(FunctionExpression<Function2<TSource,java.lang.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 asselect(org.apache.calcite.linq4j.tree.FunctionExpression)
.
-
selectMany
<TResult> Queryable<TResult> selectMany(FunctionExpression<Function1<TSource,Enumerable<TResult>>> selector)
Projects each element of a sequence to anEnumerable<TSource>
and combines the resulting sequences into one sequence.
-
selectManyN
<TResult> Queryable<TResult> selectManyN(FunctionExpression<Function2<TSource,java.lang.Integer,Enumerable<TResult>>> selector)
Projects each element of a sequence to anEnumerable<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 asselectMany(org.apache.calcite.linq4j.tree.FunctionExpression)
-
selectMany
<TCollection,TResult> Queryable<TResult> selectMany(FunctionExpression<Function2<TSource,java.lang.Integer,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<TSource,TCollection,TResult>> resultSelector)
Projects each element of a sequence to anEnumerable<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<TSource,Enumerable<TCollection>>> collectionSelector, FunctionExpression<Function2<TSource,TCollection,TResult>> resultSelector)
Projects each element of a sequence to anEnumerable<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 asselectMany(org.apache.calcite.linq4j.tree.FunctionExpression, org.apache.calcite.linq4j.tree.FunctionExpression)
-
single
TSource single(FunctionExpression<Predicate1<TSource>> 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
TSource 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 interfaceExtendedEnumerable<TSource>
-
singleOrDefault
TSource singleOrDefault(FunctionExpression<Predicate1<TSource>> 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<TSource> skip(int count)
Bypasses a specified number of elements in a sequence and then returns the remaining elements.- Specified by:
skip
in interfaceExtendedEnumerable<TSource>
-
skipWhile
Queryable<TSource> skipWhile(FunctionExpression<Predicate1<TSource>> predicate)
Bypasses elements in a sequence as long as a specified condition is true and then returns the remaining elements.
-
skipWhileN
Queryable<TSource> skipWhileN(FunctionExpression<Predicate2<TSource,java.lang.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
java.math.BigDecimal sumBigDecimal(FunctionExpression<BigDecimalFunction1<TSource>> 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
java.math.BigDecimal sumNullableBigDecimal(FunctionExpression<NullableBigDecimalFunction1<TSource>> 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<TSource>> 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
java.lang.Double sumNullableDouble(FunctionExpression<NullableDoubleFunction1<TSource>> 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<TSource>> 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
java.lang.Integer sumNullableInteger(FunctionExpression<NullableIntegerFunction1<TSource>> 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<TSource>> 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
java.lang.Long sumNullableLong(FunctionExpression<NullableLongFunction1<TSource>> 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<TSource>> 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
java.lang.Float sumNullableFloat(FunctionExpression<NullableFloatFunction1<TSource>> 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<TSource> take(int count)
Returns a specified number of contiguous elements from the start of a sequence.- Specified by:
take
in interfaceExtendedEnumerable<TSource>
-
takeWhile
Queryable<TSource> takeWhile(FunctionExpression<Predicate1<TSource>> predicate)
Returns elements from a sequence as long as a specified condition is true.
-
takeWhileN
Queryable<TSource> takeWhileN(FunctionExpression<Predicate2<TSource,java.lang.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<TSource> union(Enumerable<TSource> source1)
Produces the set union of two sequences by using the default equality comparer.- Specified by:
union
in interfaceExtendedEnumerable<TSource>
-
union
Queryable<TSource> union(Enumerable<TSource> source1, EqualityComparer<TSource> comparer)
Produces the set union of two sequences by using a specifiedEqualityComparer<TSource>
.- Specified by:
union
in interfaceExtendedEnumerable<TSource>
-
where
Queryable<TSource> where(FunctionExpression<? extends Predicate1<TSource>> predicate)
Filters a sequence of values based on a predicate.
-
whereN
Queryable<TSource> whereN(FunctionExpression<? extends Predicate2<TSource,java.lang.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<TSource,T1,TResult>> resultSelector)
Merges two sequences by using the specified predicate function.
-
-