Injector¶

Injector is an abstraction of injectors to fill in statements with more information for execution (e.g., a schema or a kafka topic).

Contract¶

Injecting Metadata¶

<T extends Statement> ConfiguredStatement<T> inject(
  ConfiguredStatement<T> statement)

Used when:

• KsqlContext is requested to execute a statement
• StatementExecutor is requested to prepare a statement
• DistributingExecutor is requested to execute a statement
• RequestValidator is requested to validate a statement

Implementations¶

• DefaultFormatInjector
• DefaultSchemaInjector
• InjectorChain
• SchemaRegisterInjector
• SourcePropertyInjector
• TopicCreateInjector
• TopicDeleteInjector