KsqlPlanV1¶

KsqlPlanV1 is a KsqlPlan that EngineExecutor uses to hold the result of planning statements (as a container for a DdlCommand, a QueryPlan or both):

1. ExecutableDdlStatement with a non-source table (gives a DdlCommand only)
2. ExecutableDdlStatement with a source table (gives a DdlCommand and a QueryPlan for changes)
3. QueryContainer (gives a QueryPlan and perhaps a DdlCommand to create a sink)

Creating Instance¶

KsqlPlanV1 takes the following to be created:

• Statement Text
• (optional) DdlCommand
• (optional) QueryPlan

When created, KsqlPlanV1 makes sure that either a DdlCommand or a QueryPlan is given.

KsqlPlanV1 is created when:

• KsqlPlan utility is used to create a KsqlPlan for a DdlCommand or a QueryPlan
• KsqlPlanV1 is requested for a copy of the current KsqlPlanV1 without a query plan

Current KsqlPlanV1 Without QueryPlan (withoutQuery)¶

KsqlPlan withoutQuery()

withoutQuery creates a new KsqlPlanV1 (with the statementText and the ddlCommand but with no QueryPlan).

withoutQuery is part of the KsqlPlan abstraction.