Skip to content

CreateSource

CreateSource is an extension of the Statement abstraction for CREATE SOURCE statements.

Contract

copyWith

CreateSource copyWith(
  TableElements elements,
  CreateSourceProperties properties)

Overrides TableElements and CreateSourceProperties of this CreateSource

Used when:

  • StatementRewriter.Rewriter is requested to visitCreateStream and visitCreateTable
  • DefaultFormatInjector is requested to injectForCreateStatement
  • DefaultSchemaInjector is requested to addSchemaFields
  • SourcePropertyInjector is requested to buildConfiguredStatement
  • TopicCreateInjector is requested to injectForCreateSource

getSourceType

SourceType getSourceType()

Implementations

Creating Instance

CreateSource takes the following to be created:

Abstract Class

CreateSource is an abstract class and cannot be created directly. It is created indirectly for the concrete CreateSources.