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 schemaKStream
• SchemaKStream is requested to into, filter, flatMap and others