Package org.apache.calcite.adapter.elasticsearch

Class ElasticsearchTable.ElasticsearchQueryable<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.elasticsearch.ElasticsearchTable.ElasticsearchQueryable<T>

Type Parameters:

T - element 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:

ElasticsearchTable

public static class ElasticsearchTable.ElasticsearchQueryable<T>
extends AbstractTableQueryable<T>

Implementation of Queryable based on a ElasticsearchTable.

Field Summary

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

queryProvider, schema, table, tableName

Constructor Summary

Constructors

Constructor	Description
ElasticsearchQueryable(QueryProvider queryProvider, SchemaPlus schema, ElasticsearchTable table, java.lang.String tableName)

Method Summary

Modifier and Type	Method	Description
Enumerator<T>	enumerator()	Returns an enumerator that iterates through a collection.
Enumerable<java.lang.Object>	find(java.util.List<java.lang.String> ops, java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields, java.util.List<java.util.Map.Entry<java.lang.String,RelFieldCollation.Direction>> sort, java.util.List<java.lang.String> groupBy, java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> aggregations, java.lang.Long offset, java.lang.Long fetch)	Called via code-generation.
private ElasticsearchTable	getTable()

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

ElasticsearchQueryable

ElasticsearchQueryable(QueryProvider queryProvider,
                       SchemaPlus schema,
                       ElasticsearchTable 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 ElasticsearchTable getTable()

find

public Enumerable<java.lang.Object> find(java.util.List<java.lang.String> ops,
                                         java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields,
                                         java.util.List<java.util.Map.Entry<java.lang.String,RelFieldCollation.Direction>> sort,
                                         java.util.List<java.lang.String> groupBy,
                                         java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> aggregations,
                                         java.lang.Long offset,
                                         java.lang.Long fetch)

Called via code-generation.

Parameters:

ops - list of queries (as strings)

fields - projection

Returns:

result as enumerable

See Also:

ElasticsearchMethod.ELASTICSEARCH_QUERYABLE_FIND