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 facbd8b975f104e2347892e86f79de5f1641fab9..04639219a365065ee8fafb5da7a2d1d3d5daafd9 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.