From c152dde78f73d5ce3a483fd60a47e7de1f1916da Mon Sep 17 00:00:00 2001
From: Jacky Li <jacky.likun@huawei.com>
Date: Thu, 11 Dec 2014 22:44:27 -0800
Subject: [PATCH] [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
---
.../org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 8 +++++---
1 file 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.
--
GitLab