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

Class IngestHandler.InsertHandler

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

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

All Implemented Interfaces:

SqlStatementHandler

Enclosing class:

IngestHandler

protected static class IngestHandler.InsertHandler
extends IngestHandler

Handler for the INSERT statement.

Nested Class Summary

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

IngestHandler.InsertHandler, IngestHandler.ReplaceHandler

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 inherited from class org.apache.druid.sql.calcite.planner.IngestHandler

ingestionGranularity, 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

Constructor Summary

Constructors

Constructor	Description
InsertHandler(SqlStatementHandler.HandlerContext handlerContext, DruidSqlInsert sqlNode, org.apache.calcite.sql.SqlExplain explain)

Method Summary

Modifier and Type	Method	Description
protected static DruidSqlInsert	convertQuery(DruidSqlIngest sqlNode)
ExplainAttributes	explainAttributes()
protected DruidSqlIngest	ingestNode()
void	validate()

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

buildQueryMaker, convertSourceQuery, operationName, planForDruid, returnedRowType, validatedQueryNode

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

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

Constructor Details

InsertHandler

public InsertHandler(SqlStatementHandler.HandlerContext handlerContext,
 DruidSqlInsert sqlNode,
 org.apache.calcite.sql.SqlExplain explain)

Method Details

convertQuery

protected static DruidSqlInsert convertQuery(DruidSqlIngest sqlNode)

ingestNode

protected DruidSqlIngest ingestNode()

Specified by:

ingestNode in class IngestHandler

validate

public void validate()

Specified by:

validate in interface SqlStatementHandler

Overrides:

validate in class IngestHandler

explainAttributes

public ExplainAttributes explainAttributes()

Specified by:

explainAttributes in interface SqlStatementHandler

Overrides:

explainAttributes in class QueryHandler