Skip to content

Commit

Permalink
fix conflicts empty lines and spaces
Browse files Browse the repository at this point in the history
  • Loading branch information
fjiang6 committed Jul 29, 2015
1 parent e693c54 commit 952dcab
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -189,10 +189,10 @@ class SqlParser extends AbstractSparkSQLParser with DataTypeParser {

protected lazy val joinType: Parser[JoinType] =
( INNER ^^^ Inner
| LEFT ~ SEMI ^^^ LeftSemi
| LEFT ~ OUTER.? ^^^ LeftOuter
| LEFT ~ SEMI ^^^ LeftSemi
| LEFT ~ OUTER.? ^^^ LeftOuter
| RIGHT ~ OUTER.? ^^^ RightOuter
| FULL ~ OUTER.? ^^^ FullOuter
| FULL ~ OUTER.? ^^^ FullOuter
)

protected lazy val sortType: Parser[LogicalPlan => LogicalPlan] =
Expand Down Expand Up @@ -222,9 +222,9 @@ class SqlParser extends AbstractSparkSQLParser with DataTypeParser {

protected lazy val comparisonExpression: Parser[Expression] =
( termExpression ~ ("=" ~> termExpression) ^^ { case e1 ~ e2 => EqualTo(e1, e2) }
| termExpression ~ ("<" ~> termExpression) ^^ { case e1 ~ e2 => LessThan(e1, e2) }
| termExpression ~ ("<" ~> termExpression) ^^ { case e1 ~ e2 => LessThan(e1, e2) }
| termExpression ~ ("<=" ~> termExpression) ^^ { case e1 ~ e2 => LessThanOrEqual(e1, e2) }
| termExpression ~ (">" ~> termExpression) ^^ { case e1 ~ e2 => GreaterThan(e1, e2) }
| termExpression ~ (">" ~> termExpression) ^^ { case e1 ~ e2 => GreaterThan(e1, e2) }
| termExpression ~ (">=" ~> termExpression) ^^ { case e1 ~ e2 => GreaterThanOrEqual(e1, e2) }
| termExpression ~ ("!=" ~> termExpression) ^^ { case e1 ~ e2 => Not(EqualTo(e1, e2)) }
| termExpression ~ ("<>" ~> termExpression) ^^ { case e1 ~ e2 => Not(EqualTo(e1, e2)) }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -161,17 +161,17 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
allAggregates(rewrittenAggregateExpressions)) &&
codegenEnabled &&
!canBeConvertedToNewAggregation(plan) =>
execution.GeneratedAggregate(
partial = false,
namedGroupingAttributes,
rewrittenAggregateExpressions,
unsafeEnabled,
execution.GeneratedAggregate(
partial = true,
groupingExpressions,
partialComputation,
partial = false,
namedGroupingAttributes,
rewrittenAggregateExpressions,
unsafeEnabled,
planLater(child))) :: Nil
execution.GeneratedAggregate(
partial = true,
groupingExpressions,
partialComputation,
unsafeEnabled,
planLater(child))) :: Nil

// Cases where some aggregate can not be codegened
case PartialAggregation(
Expand Down

0 comments on commit 952dcab

Please sign in to comment.