Skip to content

InteractiveStatementExecutor

handleStatement

void handleStatement(
  QueuedCommand queuedCommand)

handleStatement handles the Command (from the given QueuedCommand and with the EXECUTE mode).

handleStatement is used when:

handleRestore

void handleRestore(
  QueuedCommand queuedCommand)

handleRestore...FIXME

handleRestore is used when:

handleStatementWithTerminatedQueries

void handleStatementWithTerminatedQueries(
  Command command,
  CommandId commandId,
  Optional<CommandStatusFuture> commandStatusFuture,
  Mode mode,
  long offset)

handleStatementWithTerminatedQueries is used when:

Case 1. Command with KsqlPlan

If the given Command has a KsqlPlan, handleStatementWithTerminatedQueries executes the KsqlPlan.

Others

Otherwise, handleStatementWithTerminatedQueries...FIXME

Executing Plan

void executePlan(
  Command command,
  CommandId commandId,
  Optional<CommandStatusFuture> commandStatusFuture,
  KsqlPlan plan,
  Mode mode,
  long offset)

executePlan requests the KsqlEngine to execute the given KsqlPlan.

executePlan increments queryIdGenerator internal counter.

For the KsqlPlan for a Query and the mode EXECUTE, executePlan requests the query to start.

Back to top