KsqlContext¶

Creating Instance¶

KsqlContext takes the following to be created:

ServiceContext
KsqlConfig
KsqlEngine
Injector Factory (BiFunction<KsqlExecutionContext, ServiceContext, Injector>)

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