Class MongoTable.MongoQueryable<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.mongodb.MongoTable.MongoQueryable<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:
- MongoTable
public static class MongoTable.MongoQueryable<T> extends AbstractTableQueryable<T>
Implementation ofQueryable
based on aMongoTable
.
-
-
Field Summary
-
Fields inherited from class org.apache.calcite.schema.impl.AbstractTableQueryable
queryProvider, schema, table, tableName
-
-
Constructor Summary
Constructors Constructor Description MongoQueryable(QueryProvider queryProvider, SchemaPlus schema, MongoTable table, java.lang.String tableName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Enumerable<java.lang.Object>
aggregate(java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields, java.util.List<java.lang.String> operations)
Called via code-generation.Enumerator<T>
enumerator()
Returns an enumerator that iterates through a collection.Enumerable<java.lang.Object>
find(java.lang.String filterJson, java.lang.String projectJson, java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields)
Called via code-generation.private com.mongodb.client.MongoDatabase
getMongoDb()
private MongoTable
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
-
-
-
-
Constructor Detail
-
MongoQueryable
MongoQueryable(QueryProvider queryProvider, SchemaPlus schema, MongoTable 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.
-
getMongoDb
private com.mongodb.client.MongoDatabase getMongoDb()
-
getTable
private MongoTable getTable()
-
aggregate
public Enumerable<java.lang.Object> aggregate(java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields, java.util.List<java.lang.String> operations)
Called via code-generation.- See Also:
MongoMethod.MONGO_QUERYABLE_AGGREGATE
-
find
public Enumerable<java.lang.Object> find(java.lang.String filterJson, java.lang.String projectJson, java.util.List<java.util.Map.Entry<java.lang.String,java.lang.Class>> fields)
Called via code-generation.- Parameters:
filterJson
- Filter documentprojectJson
- Projection documentfields
- List of expected fields (and their types)- Returns:
- result of mongo query
- See Also:
MongoMethod.MONGO_QUERYABLE_FIND
-
-