SchemaKStream¶
Creating Instance¶
SchemaKStream
takes the following to be created:
- ExecutionStep of
KStreamHolder<K>
-
LogicalSchema
-
KeyFormat
- KsqlConfig
-
FunctionRegistry
SchemaKStream
is created when:
SchemaKSourceFactory
is requested to schemaKStreamSchemaKStream
is requested to into, filter, flatMap and others