Uses of Interface
org.apache.calcite.interpreter.Sink
-
Packages that use Sink Package Description org.apache.calcite.adapter.druid Query provider based on a Druid database.org.apache.calcite.adapter.enumerable Query optimizer rules for Java calling convention.org.apache.calcite.interpreter Provides an implementation of relational expressions using an interpreter. -
-
Uses of Sink in org.apache.calcite.adapter.druid
Subinterfaces of Sink in org.apache.calcite.adapter.druid Modifier and Type Interface Description private static interface
DruidConnectionImpl.RunnableQueueSink
ASink
that is alsoRunnable
.Fields in org.apache.calcite.adapter.druid declared as Sink Modifier and Type Field Description private Sink
DruidQuery.DruidQueryNode. sink
Methods in org.apache.calcite.adapter.druid with parameters of type Sink Modifier and Type Method Description private void
DruidConnectionImpl. parse(QueryType queryType, java.io.InputStream in, Sink sink, java.util.List<java.lang.String> fieldNames, java.util.List<org.apache.calcite.avatica.ColumnMetaData.Rep> fieldTypes, DruidConnectionImpl.Page page)
Parses the output of a query, sending the results to aSink
.void
DruidConnectionImpl. request(QueryType queryType, java.lang.String data, Sink sink, java.util.List<java.lang.String> fieldNames, java.util.List<org.apache.calcite.avatica.ColumnMetaData.Rep> fieldTypes, DruidConnectionImpl.Page page)
Executes a query request. -
Uses of Sink in org.apache.calcite.adapter.enumerable
Fields in org.apache.calcite.adapter.enumerable declared as Sink Modifier and Type Field Description private Sink
EnumerableInterpretable.EnumerableNode. sink
-
Uses of Sink in org.apache.calcite.interpreter
Classes in org.apache.calcite.interpreter that implement Sink Modifier and Type Class Description private static class
Interpreter.DuplicatingSink
Implementation ofSink
using aArrayDeque
.private static class
Interpreter.ListSink
Implementation ofSink
using aArrayDeque
.Fields in org.apache.calcite.interpreter declared as Sink Modifier and Type Field Description protected Sink
AbstractSingleNode. sink
private Sink
JoinNode. sink
private Sink
UnionNode. sink
private Sink
ValuesNode. sink
Fields in org.apache.calcite.interpreter with type parameters of type Sink Modifier and Type Field Description java.util.Map<RelNode,java.util.List<Sink>>
InterpretableRel.InterpreterImplementor. relSinks
Methods in org.apache.calcite.interpreter that return Sink Modifier and Type Method Description Sink
Compiler. sink(RelNode rel)
Creates a Sink for a relational expression to write into.Sink
Interpreter.CompilerImpl. sink(RelNode rel)
Methods in org.apache.calcite.interpreter with parameters of type Sink Modifier and Type Method Description void
AggregateNode.Grouping. end(Sink sink)
-