OutputNode¶

OutputNode is an extension of the SingleSourcePlanNode abstraction for output nodes.

Contract¶

Optional Sink Name¶

Optional<SourceName> getSinkName()

The name of a stream or table (to write into)

Used when:

• CreateSourceFactory is requested to createStreamCommand and createTableCommand
• EngineExecutor is requested to plan a statement, maybeCreateSinkDdl, validateExistingSink
• QueryIdUtil is requested to buildId

Implementations¶

• KsqlBareOutputNode
• KsqlStructuredDataOutputNode

Creating Instance¶

OutputNode takes the following to be created:

• PlanNodeId
• Source PlanNode
• LogicalSchema
• Limit
• TimestampColumn