org.apache.druid.sql.calcite.run

Class NativeQueryMaker

java.lang.Object

org.apache.druid.sql.calcite.run.NativeQueryMaker

All Implemented Interfaces:

QueryMaker

public class NativeQueryMaker
extends Object
implements QueryMaker

Constructor Summary

Constructors

Constructor and Description
NativeQueryMaker(QueryLifecycleFactory queryLifecycleFactory, PlannerContext plannerContext, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, List<org.apache.calcite.util.Pair<Integer,String>> fieldMapping)

Method Summary

Modifier and Type	Method and Description
Sequence<Object[]>	runQuery(DruidQuery druidQuery) Executes a given Druid query, which is expected to correspond to the SQL query that this QueryMaker was originally created for.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NativeQueryMaker

public NativeQueryMaker(QueryLifecycleFactory queryLifecycleFactory,
                        PlannerContext plannerContext,
                        com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                        List<org.apache.calcite.util.Pair<Integer,String>> fieldMapping)

Method Detail

runQuery

public Sequence<Object[]> runQuery(DruidQuery druidQuery)

Description copied from interface: QueryMaker

Executes a given Druid query, which is expected to correspond to the SQL query that this QueryMaker was originally created for. The returned arrays match the row type given by SqlEngine.resultTypeForSelect(org.apache.calcite.rel.type.RelDataTypeFactory, org.apache.calcite.rel.type.RelDataType) or SqlEngine.resultTypeForInsert(org.apache.calcite.rel.type.RelDataTypeFactory, org.apache.calcite.rel.type.RelDataType), depending on the nature of the statement.

Specified by:

runQuery in interface QueryMaker