Skip to content

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:

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

Back to top