aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJacky Li <jacky.likun@huawei.com>2014-12-11 22:44:27 -0800
committerMichael Armbrust <michael@databricks.com>2014-12-11 22:44:27 -0800
commitc152dde78f73d5ce3a483fd60a47e7de1f1916da (patch)
tree04ce398ede4ca5471ee492e67d2711a6b7acd04d
parenta7f07f511c0783db3b2b0a19fc71814cda94aad8 (diff)
downloadspark-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.scala8
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.