Skip to content

FlatMapNode

FlatMapNode is a SingleSourcePlanNode.

Creating Instance

FlatMapNode takes the following to be created:

FlatMapNode is created when:

Building SchemaKStream

SchemaKStream<?> buildStream(
  PlanBuildContext buildContext)

buildStream requests the source node to build a SchemaKStream to flatMap.

buildStream is part of the PlanNode abstraction.

Back to top