KsqlStructuredDataOutputNode¶

KsqlStructuredDataOutputNode is an OutputNode.

Creating Instance¶

KsqlStructuredDataOutputNode takes the following to be created:

• PlanNodeId
• Parent PlanNode
• LogicalSchema
• TimestampColumn
• KsqlTopic
• Limit
• doCreateInto flag
• Sink Name
• orReplace flag

KsqlStructuredDataOutputNode is created when:

• LogicalPlanner is requested to build an OutputNode (for a QueryContainer)

Building SchemaKStream¶

SchemaKStream<?> buildStream(
  PlanBuildContext buildContext)

buildStream requests the source PlanNode to build a SchemaKStream.

In the end, buildStream requests the SchemaKStream to into (for the ksqlTopic and the timestampColumn).

buildStream is part of the PlanNode abstraction.