Type Members

1.  class ApplyV2Streaming extends Rule[LogicalPlan]

   Rule for applying the V2 streaming path by rewriting V1 StreamingRelation with Delta DataSource to StreamingRelationV2 with SparkTable.

   Rule for applying the V2 streaming path by rewriting V1 StreamingRelation with Delta DataSource to StreamingRelationV2 with SparkTable.

   This rule handles the case where Spark's FindDataSourceTable rule has converted a StreamingRelationV2 (with DeltaTableV2) back to a StreamingRelation because DeltaTableV2 doesn't advertise STREAMING_READ capability. We convert it back to StreamingRelationV2 with SparkTable (from sparkV2) which does support streaming.

   See DeltaV2Mode for configuration behavior.