Skip to content


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:

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.