SourceBuilder¶

SourceBuilder is a SourceBuilderBase.

SourceBuilder Instance¶

SourceBuilder defines instance static value with an instance of SourceBuilder.

The instance is used when:

KSPlanBuilder is requested to visitTableSource

Building KTable¶

KTable<K, GenericRow> buildKTable(
  SourceStep<?> streamSource,
  RuntimeBuildContext buildContext,
  Consumed<K, GenericRow> consumed,
  Function<K, Collection<?>> keyGenerator,
  Materialized<K, GenericRow, KeyValueStore<Bytes, byte[]>> materialized,
  Serde<GenericRow> valueSerde,
  String stateStoreName,
  PlanInfo planInfo)

buildKTable...FIXME

buildKTable is part of the SourceBuilderBase abstraction.