1

Author: aakash-db

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/Flow.scala

@@ -93,7 +93,7 @@ trait FlowFunction extends Logging {
  * Holds the [[DataFrame]] returned by a [[FlowFunction]] along with the inputs used to
  * construct it.
  * @param batchInputs the complete inputs read by the flow
- * @param sreamingInputs the incremental inputs read by the flow
+ * @param streamingInputs the incremental inputs read by the flow
  * @param usedExternalInputs the identifiers of the external inputs read by the flow
  * @param dataFrame the [[DataFrame]] expression executed by the flow if the flow can be resolved
  */

sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/elements.scala

@@ -126,9 +126,8 @@ case class Table(
     baseOrigin: QueryOrigin,
     isStreamingTableOpt: Option[Boolean],
     format: Option[String]
-) extends GraphElement
-    with Output
-    with TableInput {
+) extends TableInput
+    with Output {
 
   override val origin: QueryOrigin = baseOrigin.copy(
     objectType = Some("table"),