Skip to content

SchemaKSourceFactory

Building SchemaKStream

SchemaKStream<?> buildSource(
  PlanBuildContext buildContext,
  DataSource dataSource,
  QueryContext.Stacker contextStacker)

buildSource requests the given DataSource whether it is windowed or not and the type.

For KSTREAM type, buildSource builds a windowed or regular stream based on whether it is windowed or not, respectively.

For KTABLE type, buildSource builds a windowed or regular table based on whether it is windowed or not, respectively.

buildSource is used when:

buildStream

SchemaKStream<?> buildStream(
  PlanBuildContext buildContext,
  DataSource dataSource,
  Stacker contextStacker)

buildStream creates a new SchemaKStream with a StreamSource.

buildWindowedStream

SchemaKStream<?> buildWindowedStream(
  PlanBuildContext buildContext,
  DataSource dataSource,
  Stacker contextStacker)

buildWindowedStream...FIXME

schemaKStream

SchemaKStream<K> schemaKStream(
  PlanBuildContext buildContext,
  LogicalSchema schema,
  KeyFormat keyFormat,
  SourceStep<KStreamHolder<K>> streamSource)

schemaKStream creates a SchemaKStream.

Back to top