Repository: spark Updated Branches: refs/heads/master a7f07f511 -> c152dde78
[SPARK-4639] [SQL] Pass maxIterations in as a parameter in Analyzer fix a TODO in Analyzer: // TODO: pass this in as a parameter val fixedPoint = FixedPoint(100) Author: Jacky Li <jacky.li...@huawei.com> Closes #3499 from jackylk/config and squashes the following commits: 4c1252c [Jacky Li] fix scalastyle 820f460 [Jacky Li] pass maxIterations in as a parameter Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c152dde7 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c152dde7 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c152dde7 Branch: refs/heads/master Commit: c152dde78f73d5ce3a483fd60a47e7de1f1916da Parents: a7f07f5 Author: Jacky Li <jacky.li...@huawei.com> Authored: Thu Dec 11 22:44:27 2014 -0800 Committer: Michael Armbrust <mich...@databricks.com> Committed: Thu Dec 11 22:44:27 2014 -0800 ---------------------------------------------------------------------- .../org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/c152dde7/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala ---------------------------------------------------------------------- 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 facbd8b..0463921 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 @@ -34,13 +34,15 @@ object SimpleAnalyzer extends Analyzer(EmptyCatalog, EmptyFunctionRegistry, true * [[UnresolvedRelation]]s into fully typed objects using information in a schema [[Catalog]] and * a [[FunctionRegistry]]. */ -class Analyzer(catalog: Catalog, registry: FunctionRegistry, caseSensitive: Boolean) +class Analyzer(catalog: Catalog, + registry: FunctionRegistry, + caseSensitive: Boolean, + maxIterations: Int = 100) extends RuleExecutor[LogicalPlan] with HiveTypeCoercion { val resolver = if (caseSensitive) caseSensitiveResolution else caseInsensitiveResolution - // TODO: pass this in as a parameter. - val fixedPoint = FixedPoint(100) + val fixedPoint = FixedPoint(maxIterations) /** * Override to provide additional rules for the "Resolution" batch. --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
