diff options
author | Jacky Li <jacky.likun@huawei.com> | 2014-12-11 22:44:27 -0800 |
---|---|---|
committer | Michael Armbrust <michael@databricks.com> | 2014-12-11 22:44:27 -0800 |
commit | c152dde78f73d5ce3a483fd60a47e7de1f1916da (patch) | |
tree | 04ce398ede4ca5471ee492e67d2711a6b7acd04d | |
parent | a7f07f511c0783db3b2b0a19fc71814cda94aad8 (diff) | |
download | spark-c152dde78f73d5ce3a483fd60a47e7de1f1916da.tar.gz spark-c152dde78f73d5ce3a483fd60a47e7de1f1916da.tar.bz2 spark-c152dde78f73d5ce3a483fd60a47e7de1f1916da.zip |
[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.likun@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
-rw-r--r-- | sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 8 |
1 files changed, 5 insertions, 3 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 facbd8b975..04639219a3 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. |