File tree Expand file tree Collapse file tree
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -69,13 +69,10 @@ abstract class CodeGenerator extends Logging {
6969 * @param objectTerm An possibly boxed version of the result of evaluating this expression.
7070 */
7171 protected case class EvaluatedExpression (
72- code : Seq [Tree ],
73- nullTerm : TermName ,
74- primitiveTerm : TermName ,
75- objectTerm : TermName ) {
76-
77- def withObjectTerm = ???
78- }
72+ code : Seq [Tree ],
73+ nullTerm : TermName ,
74+ primitiveTerm : TermName ,
75+ objectTerm : TermName )
7976
8077 /**
8178 * Given an expression tree returns the code required to determine both if the result is NULL
Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ package object expressions {
5454 abstract class MutableProjection extends Projection {
5555 def currentValue : Row
5656
57- /* Updates the target of this projection to a new MutableRow */
57+ /** Updates the target of this projection to a new MutableRow */
5858 def target (row : MutableRow ): MutableProjection
5959 }
6060}
Original file line number Diff line number Diff line change @@ -72,6 +72,7 @@ abstract class RuleExecutor[TreeType <: TreeNode[_]] extends Logging {
7272 }
7373 iteration += 1
7474 if (iteration > batch.strategy.maxIterations) {
75+ // Only log if this is a rule that is supposed to run more than once.
7576 if (iteration != 2 ) {
7677 logger.info(s " Max iterations ( ${iteration - 1 }) reached for batch ${batch.name}" )
7778 }
You can’t perform that action at this time.
0 commit comments