StatementExecutor¶

StatementExecutor is an abstraction of executors of Statements.

StatementExecutor is a FunctionalInterface (Java).

Contract¶

Executing Statement¶

StatementExecutorResponse execute(
  ConfiguredStatement<T> statement,
  SessionProperties sessionProperties,
  KsqlExecutionContext executionContext,
  ServiceContext serviceContext)

Used when:

• CustomExecutors is requested to execute
• RequestHandler is requested to execute a SQL statement

Implementations¶

• many