Author: daijy
Date: Mon Oct 19 21:18:09 2009
New Revision: 826816
URL: http://svn.apache.org/viewvc?rev=826816&view=rev
Log:
PIG-644: Duplicate column names in foreach do not throw parser error
Added:
hadoop/pig/trunk/src/org/apache/pig/impl/logicalLayer/validators/SchemaAliasValidator.java
Added:
hadoop/pig/trunk/src/org/apache/pig/impl/logicalLayer/validators/SchemaAliasValidator.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/impl/logicalLayer/validators/SchemaAliasValidator.java?rev=826816&view=auto
==============================================================================
---
hadoop/pig/trunk/src/org/apache/pig/impl/logicalLayer/validators/SchemaAliasValidator.java
(added)
+++
hadoop/pig/trunk/src/org/apache/pig/impl/logicalLayer/validators/SchemaAliasValidator.java
Mon Oct 19 21:18:09 2009
@@ -0,0 +1,22 @@
+package org.apache.pig.impl.logicalLayer.validators;
+
+import org.apache.pig.impl.logicalLayer.LogicalOperator;
+import org.apache.pig.impl.logicalLayer.LogicalPlan;
+import org.apache.pig.impl.plan.CompilationMessageCollector;
+import org.apache.pig.impl.plan.PlanValidationException;
+import org.apache.pig.impl.plan.PlanValidator;
+
+public class SchemaAliasValidator extends PlanValidator<LogicalOperator,
LogicalPlan> {
+ public SchemaAliasValidator() {
+ }
+
+ public void validate(LogicalPlan plan,
+ CompilationMessageCollector msgCollector)
+ throws PlanValidationException {
+ // The first msgCollector is used in visitor
+ // The second msgCollector is used by the validator
+ super.validateSkipCollectException(new SchemaAliasVisitor(plan),
+ msgCollector) ;
+
+ }
+}
