Package org.apache.druid.sql.calcite.planner

Class IngestHandler

java.lang.Object

org.apache.druid.sql.calcite.planner.SqlStatementHandler.BaseStatementHandler

org.apache.druid.sql.calcite.planner.QueryHandler

org.apache.druid.sql.calcite.planner.IngestHandler

All Implemented Interfaces:

SqlStatementHandler

Direct Known Subclasses:

IngestHandler.InsertHandler, IngestHandler.ReplaceHandler

public abstract class IngestHandler
extends QueryHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	IngestHandler.InsertHandler	Handler for the INSERT statement.
protected static class	IngestHandler.ReplaceHandler	Handler for the REPLACE statement.

Nested classes/interfaces inherited from class org.apache.druid.sql.calcite.planner.QueryHandler

QueryHandler.SelectHandler

Nested classes/interfaces inherited from interface org.apache.druid.sql.calcite.planner.SqlStatementHandler

SqlStatementHandler.BaseStatementHandler, SqlStatementHandler.HandlerContext

Field Summary

Fields

Modifier and Type	Field	Description
protected Granularity	ingestionGranularity
protected IngestDestination	targetDatasource

Fields inherited from class org.apache.druid.sql.calcite.planner.QueryHandler

explain, rexBuilder, rootQueryRel

Fields inherited from class org.apache.druid.sql.calcite.planner.SqlStatementHandler.BaseStatementHandler

handlerContext, resourceActions

Method Summary

Modifier and Type	Method	Description
protected QueryMaker	buildQueryMaker(org.apache.calcite.rel.RelRoot rootQueryRel)
protected static org.apache.calcite.sql.SqlNode	convertSourceQuery(DruidSqlIngest sqlNode)
protected abstract DruidSqlIngest	ingestNode()
protected String	operationName()
protected PlannerResult	planForDruid()
protected org.apache.calcite.rel.type.RelDataType	returnedRowType()
void	validate()
protected org.apache.calcite.sql.SqlNode	validatedQueryNode()

Methods inherited from class org.apache.druid.sql.calcite.planner.QueryHandler

explainAttributes, plan, planExplanation, planWithDruidConvention, prepare, prepareResult, validate

Methods inherited from class org.apache.druid.sql.calcite.planner.SqlStatementHandler.BaseStatementHandler

resourceActions

Methods inherited from class java.lang.Object

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

Field Details

ingestionGranularity

protected Granularity ingestionGranularity

targetDatasource

protected IngestDestination targetDatasource

Method Details

convertSourceQuery

protected static org.apache.calcite.sql.SqlNode convertSourceQuery(DruidSqlIngest sqlNode)

operationName

protected String operationName()

ingestNode

protected abstract DruidSqlIngest ingestNode()

validate

public void validate()

validatedQueryNode

protected org.apache.calcite.sql.SqlNode validatedQueryNode()

Specified by:

validatedQueryNode in class QueryHandler

returnedRowType

protected org.apache.calcite.rel.type.RelDataType returnedRowType()

Specified by:

returnedRowType in class QueryHandler

planForDruid

protected PlannerResult planForDruid()
                              throws org.apache.calcite.tools.ValidationException

Specified by:

planForDruid in class QueryHandler

Throws:

org.apache.calcite.tools.ValidationException

buildQueryMaker

protected QueryMaker buildQueryMaker(org.apache.calcite.rel.RelRoot rootQueryRel)
                              throws org.apache.calcite.tools.ValidationException

Specified by:

buildQueryMaker in class QueryHandler

Throws:

org.apache.calcite.tools.ValidationException