Skip to content
Snippets Groups Projects
Commit c152dde7 authored by Jacky Li's avatar Jacky Li Committed by Michael Armbrust
Browse files

[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
parent a7f07f51
No related branches found
No related tags found
No related merge requests found
...@@ -34,13 +34,15 @@ object SimpleAnalyzer extends Analyzer(EmptyCatalog, EmptyFunctionRegistry, true ...@@ -34,13 +34,15 @@ object SimpleAnalyzer extends Analyzer(EmptyCatalog, EmptyFunctionRegistry, true
* [[UnresolvedRelation]]s into fully typed objects using information in a schema [[Catalog]] and * [[UnresolvedRelation]]s into fully typed objects using information in a schema [[Catalog]] and
* a [[FunctionRegistry]]. * 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 { extends RuleExecutor[LogicalPlan] with HiveTypeCoercion {
val resolver = if (caseSensitive) caseSensitiveResolution else caseInsensitiveResolution val resolver = if (caseSensitive) caseSensitiveResolution else caseInsensitiveResolution
// TODO: pass this in as a parameter. val fixedPoint = FixedPoint(maxIterations)
val fixedPoint = FixedPoint(100)
/** /**
* Override to provide additional rules for the "Resolution" batch. * Override to provide additional rules for the "Resolution" batch.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment