Class ElasticsearchRel.Implementor
- java.lang.Object
-
- org.apache.calcite.adapter.elasticsearch.ElasticsearchRel.Implementor
-
- Enclosing interface:
- ElasticsearchRel
public static class ElasticsearchRel.Implementor extends java.lang.Object
Callback for the implementation process that converts a tree ofElasticsearchRel
nodes into an Elasticsearch query.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>>
aggregations
Elastic aggregation (MIN / MAX / COUNT
etc.) statements (functions).(package private) ElasticsearchTable
elasticsearchTable
(package private) java.lang.Long
fetch
Number of records to return.(package private) java.util.List<java.lang.String>
groupBy
Allows bucketing documents together.(package private) java.util.List<java.lang.String>
list
(package private) java.lang.Long
offset
Starting index (default0
).(package private) java.util.List<java.util.Map.Entry<java.lang.String,RelFieldCollation.Direction>>
sort
Sorting clauses.(package private) RelOptTable
table
-
Constructor Summary
Constructors Constructor Description Implementor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
add(java.lang.String findOp)
(package private) void
addAggregation(java.lang.String field, java.lang.String expression)
(package private) void
addGroupBy(java.lang.String field)
(package private) void
addSort(java.lang.String field, RelFieldCollation.Direction direction)
(package private) void
fetch(long fetch)
(package private) void
offset(long offset)
(package private) void
visitChild(int ordinal, RelNode input)
-
-
-
Field Detail
-
list
final java.util.List<java.lang.String> list
-
sort
final java.util.List<java.util.Map.Entry<java.lang.String,RelFieldCollation.Direction>> sort
Sorting clauses.- See Also:
- Sort
-
aggregations
final java.util.List<java.util.Map.Entry<java.lang.String,java.lang.String>> aggregations
Elastic aggregation (MIN / MAX / COUNT
etc.) statements (functions).- See Also:
- aggregations
-
groupBy
final java.util.List<java.lang.String> groupBy
Allows bucketing documents together. Similar toselect ... from table group by field1
- See Also:
- Bucket Aggregrations
-
offset
java.lang.Long offset
Starting index (default0
). Equivalent tostart
in ES query.- See Also:
- From/Size
-
fetch
java.lang.Long fetch
Number of records to return. Equivalent tosize
in ES query.- See Also:
- From/Size
-
table
RelOptTable table
-
elasticsearchTable
ElasticsearchTable elasticsearchTable
-
-
Method Detail
-
add
void add(java.lang.String findOp)
-
addGroupBy
void addGroupBy(java.lang.String field)
-
addSort
void addSort(java.lang.String field, RelFieldCollation.Direction direction)
-
addAggregation
void addAggregation(java.lang.String field, java.lang.String expression)
-
offset
void offset(long offset)
-
fetch
void fetch(long fetch)
-
visitChild
void visitChild(int ordinal, RelNode input)
-
-