ExplainExecutor¶

ExplainExecutor is a utility to explain queries or statements.

Executing Explain¶

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

execute creates a StatementExecutorResponse with explain (for the given arguments).

execute is used when:

CustomExecutors is requested to handle an Explain statement

Explaining Query or Statement¶

QueryDescriptionEntity explain(
  ServiceContext serviceContext,
  ConfiguredStatement<Explain> statement,
  KsqlExecutionContext executionContext,
  SessionProperties sessionProperties)

explain looks up a query ID from the given ConfiguredStatement.

If found, explain explainQuery. Otherwise, explain explainStatement.

Explaining Statement¶

QueryDescription explainStatement(
  ConfiguredStatement<Explain> explain,
  KsqlExecutionContext executionContext,
  ServiceContext serviceContext)

explainStatement...FIXME

Explaining Query¶

QueryDescription explainQuery(
  String queryId,
  KsqlExecutionContext executionContext,
  SessionProperties sessionProperties)

explainQuery...FIXME