FlatMapNode¶

FlatMapNode is a SingleSourcePlanNode.

Creating Instance¶

FlatMapNode takes the following to be created:

• PlanNodeId
• Parent PlanNode
• FunctionRegistry
• ImmutableAnalysis

FlatMapNode is created when:

• LogicalPlanner is requested to build a logical plan of a persistent query with a table function

Building SchemaKStream¶

SchemaKStream<?> buildStream(
  PlanBuildContext buildContext)

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

buildStream is part of the PlanNode abstraction.