ConfiguredKsqlPlan¶

ConfiguredKsqlPlan is a KsqlPlan with a SessionConfig.

Creating Instance¶

ConfiguredKsqlPlan takes the following to be created:

• KsqlPlan
• SessionConfig

ConfiguredKsqlPlan is created using of utility.

of¶

ConfiguredKsqlPlan of(
  KsqlPlan plan,
  SessionConfig config
)

of creates a ConfiguredKsqlPlan.

of is used when:

• KsqlEngine is requested to execute a statement
• SandboxedExecutionContext is requested to execute a statement
• InteractiveStatementExecutor is requested to execute a KsqlPlan
• ValidatedCommandFactory is requested to createForPlannedQuery