SourceBuilderUtils¶

Building Value Serde¶

Serde<GenericRow> getValueSerde(
  RuntimeBuildContext buildContext,
  SourceStep<?> streamSource,
  PhysicalSchema physicalSchema)
Serde<GenericRow> getValueSerde(
  RuntimeBuildContext buildContext,
  SourceStep<?> streamSource,
  PhysicalSchema physicalSchema,
  QueryContext queryContext)

getValueSerde requests the given RuntimeBuildContext to build a value serde (Serde<GenericRow>).

getValueSerde is used when:

SourceBuilder is requested to buildTableMaterialized
SourceBuilderBase is requested to buildTable
SourceBuilderV1 is requested to buildStream, buildWindowedStream, buildWindowedTable