aboutsummaryrefslogtreecommitdiff
path: root/sql/catalyst
diff options
context:
space:
mode:
authorJosh Rosen <joshrosen@databricks.com>2015-04-11 20:12:40 -0700
committerJosh Rosen <joshrosen@databricks.com>2015-04-11 20:12:40 -0700
commitdea5dacc5d701c3dfe433360b2e17e50edec31e8 (patch)
tree44efaf6ddc37ac55e3b0a4ab7ab99650b514c400 /sql/catalyst
parent5c2844c51aca6a0da9251a3fd346a6f872cf17f8 (diff)
downloadspark-dea5dacc5d701c3dfe433360b2e17e50edec31e8.tar.gz
spark-dea5dacc5d701c3dfe433360b2e17e50edec31e8.tar.bz2
spark-dea5dacc5d701c3dfe433360b2e17e50edec31e8.zip
[HOTFIX] Add explicit return types to fix lint errors
Diffstat (limited to 'sql/catalyst')
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala2
-rw-r--r--sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala2
2 files changed, 2 insertions, 2 deletions
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
index fd1ceb1f77..50702ac683 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
@@ -169,7 +169,7 @@ class Analyzer(
* Replaces [[UnresolvedRelation]]s with concrete relations from the catalog.
*/
object ResolveRelations extends Rule[LogicalPlan] {
- def getTable(u: UnresolvedRelation, cteRelations: Map[String, LogicalPlan]) = {
+ def getTable(u: UnresolvedRelation, cteRelations: Map[String, LogicalPlan]): LogicalPlan = {
try {
// In hive, if there is same table name in database and CTE definition,
// hive will use the table in database, not the CTE one.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
index 3bd5aa5964..5d31a6eecf 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
@@ -156,7 +156,7 @@ case class CreateTableAsSelect[T](
* value is the CTE definition.
*/
case class With(child: LogicalPlan, cteRelations: Map[String, Subquery]) extends UnaryNode {
- override def output = child.output
+ override def output: Seq[Attribute] = child.output
}
case class WriteToFile(