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