Package org.apache.calcite.adapter.geode.rel

Class GeodeTable.GeodeQueryable<T>

java.lang.Object

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

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

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

org.apache.calcite.schema.impl.AbstractTableQueryable<T>

org.apache.calcite.adapter.geode.rel.GeodeTable.GeodeQueryable<T>

Type Parameters:

T - type

All Implemented Interfaces:

java.lang.Iterable<T>, Enumerable<T>, ExtendedEnumerable<T>, ExtendedOrderedEnumerable<T>, ExtendedOrderedQueryable<T>, ExtendedQueryable<T>, OrderedEnumerable<T>, OrderedQueryable<T>, Queryable<T>, RawEnumerable<T>, RawQueryable<T>

Enclosing class:

GeodeTable

public static class GeodeTable.GeodeQueryable<T>
extends AbstractTableQueryable<T>

Implementation of Queryable based on a GeodeTable.

Field Summary

Fields inherited from class org.apache.calcite.schema.impl.AbstractTableQueryable

queryProvider, schema, table, tableName

Constructor Summary

Constructors

Constructor	Description
GeodeQueryable(QueryProvider queryProvider, SchemaPlus schema, GeodeTable table, java.lang.String tableName)

Method Summary

Modifier and Type	Method	Description
Enumerator<T>	enumerator()	Returns an enumerator that iterates through a collection.
private org.apache.geode.cache.GemFireCache	getClientCache()
private GeodeTable	getTable()
Enumerable<java.lang.Object>	query(java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields, java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> selectFields, java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> aggregateFunctions, java.util.List<java.lang.String> groupByFields, java.util.List<java.lang.String> predicates, java.util.List<java.lang.String> order, java.lang.Long limit)	Called via code-generation.

Methods inherited from class org.apache.calcite.schema.impl.AbstractTableQueryable

getElementType, getExpression, getProvider, iterator

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

aggregate, aggregate, aggregate, all, any, asEnumerable, asQueryable, averageBigDecimal, averageDouble, averageFloat, averageInteger, averageLong, averageNullableBigDecimal, averageNullableDouble, averageNullableFloat, averageNullableInteger, averageNullableLong, cast, concat, count, defaultIfEmpty, distinct, distinct, except, except, first, firstOrDefault, getThis, getThisOrderedQueryable, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupByK, groupByK, groupJoin, groupJoin, intersect, intersect, join, join, last, lastOrDefault, longCount, max, min, ofType, orderBy, orderBy, orderByDescending, orderByDescending, reverse, select, selectMany, selectMany, selectManyN, selectManyN, selectN, single, singleOrDefault, skip, skipWhile, skipWhileN, sumBigDecimal, sumDouble, sumFloat, sumInteger, sumLong, sumNullableBigDecimal, sumNullableDouble, sumNullableFloat, sumNullableInteger, sumNullableLong, take, takeWhile, takeWhileN, thenBy, thenBy, thenByDescending, thenByDescending, union, union, where, whereN, zip

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

aggregate, aggregate, aggregate, all, any, any, 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, 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, singleOrDefault, skipWhile, skipWhile, 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, toString, 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, 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

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

aggregate, aggregate, aggregate, all, any, averageBigDecimal, averageDouble, averageFloat, averageInteger, averageLong, averageNullableBigDecimal, averageNullableDouble, averageNullableFloat, averageNullableInteger, averageNullableLong, cast, concat, count, defaultIfEmpty, distinct, distinct, except, except, first, firstOrDefault, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, groupByK, groupByK, groupJoin, groupJoin, intersect, intersect, join, join, last, lastOrDefault, longCount, max, min, ofType, orderBy, orderBy, orderByDescending, orderByDescending, reverse, select, selectMany, selectMany, selectManyN, selectManyN, selectN, single, singleOrDefault, singleOrDefault, skip, skipWhile, skipWhileN, sumBigDecimal, sumDouble, sumFloat, sumInteger, sumLong, sumNullableBigDecimal, sumNullableDouble, sumNullableFloat, sumNullableInteger, sumNullableLong, take, takeWhile, takeWhileN, union, union, where, whereN, zip

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

GeodeQueryable

public GeodeQueryable(QueryProvider queryProvider,
                      SchemaPlus schema,
                      GeodeTable table,
                      java.lang.String tableName)

Method Detail

enumerator

public Enumerator<T> enumerator()

Description copied from interface: RawEnumerable

Returns an enumerator that iterates through a collection.

getTable

private GeodeTable getTable()

getClientCache

private org.apache.geode.cache.GemFireCache getClientCache()

query

public Enumerable<java.lang.Object> query(java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields,
                                          java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> selectFields,
                                          java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> aggregateFunctions,
                                          java.util.List<java.lang.String> groupByFields,
                                          java.util.List<java.lang.String> predicates,
                                          java.util.List<java.lang.String> order,
                                          java.lang.Long limit)

Called via code-generation.