File tree Expand file tree Collapse file tree 3 files changed +2
-7
lines changed
src/main/scala/org/apache/spark/sql/pipelines/graph Expand file tree Collapse file tree 3 files changed +2
-7
lines changed Original file line number Diff line number Diff line change 43
43
<version >${project.version} </version >
44
44
<scope >test</scope >
45
45
</dependency >
46
- <dependency >
47
- <groupId >org.apache.spark</groupId >
48
- <artifactId >spark-core_${scala.binary.version}</artifactId >
49
- <version >${project.version} </version >
50
- </dependency >
51
46
<dependency >
52
47
<groupId >org.apache.spark</groupId >
53
48
<artifactId >spark-sql_${scala.binary.version}</artifactId >
Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ import org.apache.spark.sql.classic.SparkSession
25
25
import org .apache .spark .sql .pipelines .AnalysisWarning
26
26
27
27
/**
28
- * A context used when evaluating a [[Flow ]]'s query into a concrete [[ DataFrame ]] .
28
+ * A context used when evaluating a [[Flow ]]'s query into a concrete DataFrame.
29
29
*
30
30
* @param allInputs Set of identifiers for all [[Input ]]s defined in the DataflowGraph.
31
31
* @param availableInputs Inputs available to be referenced with `read` or `readStream`.
Original file line number Diff line number Diff line change @@ -80,7 +80,7 @@ case class QueryOrigin(
80
80
)
81
81
}
82
82
83
- /** Generates a [[ SourceCodeLocation ]] using the details present in the query origin. */
83
+ /** Generates a SourceCodeLocation using the details present in the query origin. */
84
84
def toSourceCodeLocation : SourceCodeLocation = SourceCodeLocation (
85
85
path = fileName,
86
86
// QueryOrigin tracks line numbers using a 1-indexed numbering scheme whereas SourceCodeLocation
You can’t perform that action at this time.
0 commit comments