Package org.apache.calcite.adapter.druid
Class DruidQuery.DruidQueryNode
- java.lang.Object
-
- org.apache.calcite.adapter.druid.DruidQuery.DruidQueryNode
-
- All Implemented Interfaces:
Node
- Enclosing class:
- DruidQuery
private static class DruidQuery.DruidQueryNode extends java.lang.Object implements Node
Interpreter node that executes a Druid query and sends the results to aSink
.
-
-
Field Summary
Fields Modifier and Type Field Description private DruidQuery
query
private DruidQuery.QuerySpec
querySpec
private Sink
sink
-
Constructor Summary
Constructors Constructor Description DruidQueryNode(Compiler interpreter, DruidQuery query)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description private static boolean
containsLimit(DruidQuery.QuerySpec querySpec)
private org.apache.calcite.avatica.ColumnMetaData.Rep
getPrimitive(RelDataTypeField field)
void
run()
-
-
-
Field Detail
-
sink
private final Sink sink
-
query
private final DruidQuery query
-
querySpec
private final DruidQuery.QuerySpec querySpec
-
-
Constructor Detail
-
DruidQueryNode
DruidQueryNode(Compiler interpreter, DruidQuery query)
-
-
Method Detail
-
run
public void run() throws java.lang.InterruptedException
-
containsLimit
private static boolean containsLimit(DruidQuery.QuerySpec querySpec)
-
getPrimitive
private org.apache.calcite.avatica.ColumnMetaData.Rep getPrimitive(RelDataTypeField field)
-
-