ResolveWriteToStream Logical Resolution Rule¶

ResolveWriteToStream is a logical resolution rule (Rule[LogicalPlan]) to resolve WriteToStreamStatement unary logical operators (into WriteToStreams).

ResolveWriteToStream is part of extendedResolutionRules (Spark SQL) of an Analyzer of the following:

• HiveSessionStateBuilder (Spark SQL)
• BaseSessionStateBuilder (Spark SQL)

Creating Instance¶

ResolveWriteToStream takes no arguments to be created.

Executing Rule¶

apply(
  plan: LogicalPlan): LogicalPlan

apply is part of the Rule (Spark SQL) abstraction.

apply resolves WriteToStreamStatement unary logical operators into WriteToStreams.

apply resolveCheckpointLocation.

With spark.sql.adaptive.enabled enabled, apply...FIXME

With spark.sql.streaming.unsupportedOperationCheck enabled, apply...FIXME