StepSchemaResolver¶

Handlers¶

StepSchemaResolver defines HANDLERS registry of ExecutionSteps and their handlers.

Resolving LogicalSchema¶

LogicalSchema resolve(
  ExecutionStep<?> step,
  LogicalSchema schema)

resolve executes the handler of the given ExecutionStep (in the HANDLERS) registry.

resolve is used when:

• SchemaKGroupedStream is requested to resolveSchema
• SchemaKSourceFactory is requested to resolve a schema (of an ExecutionStep)
• SchemaKStream is requested to resolve a schema (of an ExecutionStep)
• PlanSummary is requested to get a schema
• StreamSelectKeyBuilderV1 is requested to build a KStreamHolder for a StreamSelectKeyV1