Skip to content

KsqlContext

Creating Instance

KsqlContext takes the following to be created:

KsqlContext is created using create utility.

Creating KsqlContext

KsqlContext create(
  KsqlConfig ksqlConfig,
  ProcessingLogContext processingLogContext)

create...FIXME

Executing SQL Text

List<QueryMetadata> sql(
  String sql)
List<QueryMetadata> sql(
  String sql,
  Map<String, ?> overriddenProperties)

sql...FIXME

Executing Statement

ExecuteResult execute(
  KsqlExecutionContext executionContext,
  ParsedStatement stmt,
  KsqlConfig ksqlConfig,
  Map<String, Object> mutableSessionPropertyOverrides,
  Injector injector)

execute...FIXME

Back to top