Author: pradeepkth
Date: Mon Jan  4 22:20:03 2010
New Revision: 895802

URL: http://svn.apache.org/viewvc?rev=895802&view=rev
Log:
PIG-1090: Update sources to reflect recent changes in load-store interfaces - 
incremental commit to update LOLoad (rding via pradeepkth)

Modified:
    
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/LOLoad.java
    
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/parser/QueryParser.jjt
    
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestInputOutputFileValidator.java
    
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidator.java
    
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidatorNoSchema.java
    
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/TypeCheckingTestUtil.java
    
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/dotGraph/LogicalPlanLoader.java

Modified: 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/LOLoad.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/LOLoad.java?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/LOLoad.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/LOLoad.java
 Mon Jan  4 22:20:03 2010
@@ -24,7 +24,7 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.apache.pig.ExecType;
+import org.apache.hadoop.conf.Configuration;
 import org.apache.pig.LoadFunc;
 import org.apache.pig.LoadMetadata;
 import org.apache.pig.LoadPushDown;
@@ -33,8 +33,6 @@
 import org.apache.pig.LoadPushDown.RequiredField;
 import org.apache.pig.LoadPushDown.RequiredFieldList;
 import org.apache.pig.LoadPushDown.RequiredFieldResponse;
-import org.apache.pig.backend.datastorage.DataStorage;
-import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.pig.data.DataType;
 import org.apache.pig.impl.PigContext;
 import org.apache.pig.impl.io.FileSpec;
@@ -54,8 +52,7 @@
     transient private LoadFunc mLoadFunc;
     private String mSchemaFile;
     private Schema mEnforcedSchema = null ;
-    transient private DataStorage mStorage;
-    private ExecType mExecType;
+    transient private Configuration conf;
     private static Log log = LogFactory.getLog(LOLoad.class);
     private Schema mDeterminedSchema = null;
     private RequiredFieldList requiredFieldList;
@@ -67,23 +64,19 @@
      *            OperatorKey for this operator
      * @param inputFileSpec
      *            the file to be loaded *
-     * @param execType
-     *            the execution mode @see org.apache.pig.ExecType
-     * @param storage
-     *            the underlying storage
+     * @param conf
+     *            the read-only configuration object
      *            
-     * 
      */
     public LOLoad(LogicalPlan plan, OperatorKey key, FileSpec inputFileSpec,
-            ExecType execType, DataStorage storage) throws IOException {
+            Configuration conf) throws IOException {
         super(plan, key);
         mInputFileSpec = inputFileSpec;
         //mSchemaFile = schemaFile;
         // schemaFile is the input file since we are trying
         // to deduce the schema by looking at the input file
         mSchemaFile = inputFileSpec.getFileName();
-        mStorage = storage;
-        mExecType = execType;
+        this.conf = conf;
         // Generate a psudo alias. Since in the following script, we do not 
have alias for LOLoad, however, alias is required.
         // a = foreach (load '1') generate b0;
         this.mAlias = ""+key.getId();
@@ -147,9 +140,6 @@
                 }
 
                 if(null == mDeterminedSchema) {
-                    // Zebra loader determineSchema method depends on this 
signature
-                    if (mStorage!=null)
-                        
mStorage.getConfiguration().setProperty("pig.loader.signature", mAlias);
                     mSchema = determineSchema();
                     mDeterminedSchema  = mSchema;    
                 }
@@ -168,15 +158,9 @@
     
     private Schema determineSchema() throws IOException {
         if(LoadMetadata.class.isAssignableFrom(mLoadFunc.getClass())) {
-            // XXX: FIXME - mStorage should no longer be needed, we
-            // should use Configuration directly by passing a 
-            // Configuration object while creating LOLoad rather than
-            // a DataStorage object
             LoadMetadata loadMetadata = (LoadMetadata)mLoadFunc;
             ResourceSchema rSchema = loadMetadata.getSchema(
-                    mInputFileSpec.getFileName(), 
-                    ConfigurationUtil.toConfiguration(
-                            mStorage.getConfiguration()));
+                    mInputFileSpec.getFileName(), conf);
             return Schema.getPigSchema(rSchema);
         } else {
             return null;
@@ -271,9 +255,6 @@
             }
         } else {
             try {
-                // Zebra loader determineSchema method depends on this 
signature
-                if (mStorage!=null)
-                    
mStorage.getConfiguration().setProperty("pig.loader.signature", mAlias);
                 inputSchema = determineSchema();
             } catch (IOException ioe) {
                 mProjectionMap = null;

Modified: 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/parser/QueryParser.jjt
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/parser/QueryParser.jjt?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/parser/QueryParser.jjt
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/src/org/apache/pig/impl/logicalLayer/parser/QueryParser.jjt
 Mon Jan  4 22:20:03 2010
@@ -70,6 +70,7 @@
 import org.apache.pig.backend.datastorage.DataStorage;
 import org.apache.pig.backend.datastorage.ContainerDescriptor;
 import org.apache.pig.backend.datastorage.ElementDescriptor;
+import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.hadoop.fs.Path;
 import org.apache.pig.impl.util.LinkedMultiMap;
 
@@ -1273,7 +1274,7 @@
                 fileNameMap.put(filename, absolutePath);
             }
             lo = new LOLoad(lp, new OperatorKey(scope, getNextId()), new 
FileSpec(absolutePath, funcSpec),
-                  pigContext.getExecType(), pigContext.getFs());
+                  
ConfigurationUtil.toConfiguration(pigContext.getProperties()));
         } catch (IOException ioe) {
             // The autogenerated parser code only catches RuntimeException and
             // ParseException as special Exceptions. All others are caught as

Modified: 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestInputOutputFileValidator.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestInputOutputFileValidator.java?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestInputOutputFileValidator.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestInputOutputFileValidator.java
 Mon Jan  4 22:20:03 2010
@@ -24,6 +24,7 @@
 import org.apache.pig.FuncSpec;
 import org.apache.pig.backend.datastorage.DataStorage;
 import org.apache.pig.backend.datastorage.ElementDescriptor;
+import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.pig.impl.PigContext;
 import org.apache.pig.impl.io.FileLocalizer;
 import org.apache.pig.impl.io.FileSpec;
@@ -148,7 +149,8 @@
             new FileSpec(inputFile, new 
FuncSpec("org.apache.pig.builtin.PigStorage")) ;
         FileSpec filespec2 =
             new FileSpec(outputFile, new 
FuncSpec("org.apache.pig.builtin.PigStorage"));
-        LOLoad load = new LOLoad(plan, genNewOperatorKeyId(), filespec1, null, 
dfs) ;       
+        LOLoad load = new LOLoad(plan, genNewOperatorKeyId(), filespec1, 
+                ConfigurationUtil.toConfiguration(dfs.getConfiguration())) ;   
    
         LOStore store = new LOStore(plan, genNewOperatorKeyId(), filespec2) ;
         
         plan.add(load) ;

Modified: 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidator.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidator.java?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidator.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidator.java
 Mon Jan  4 22:20:03 2010
@@ -951,11 +951,11 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
         LOLoad load2 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1075,11 +1075,11 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
         LOLoad load2 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1247,7 +1247,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1315,7 +1315,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1383,7 +1383,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1453,7 +1453,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1533,7 +1533,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1631,7 +1631,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1726,7 +1726,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1852,7 +1852,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -1954,11 +1954,11 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
         LOLoad load2 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -2119,11 +2119,11 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
         LOLoad load2 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -2254,11 +2254,11 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
         LOLoad load2 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, null) ;
+                                  null) ;
 
         // schema for input#1
         Schema inputSchema1 = null ;
@@ -2753,8 +2753,6 @@
         printCurrentMethodName();
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
         LOLoad load2 = genDummyLOLoad(plan) ;
 
@@ -5513,13 +5511,9 @@
          * 
          */
         public CastFinder(LogicalPlan lp) {
-            // TODO Auto-generated constructor stub
             super(lp, new DepthFirstWalker<LogicalOperator, LogicalPlan>(lp));
         }
         
-        /* (non-Javadoc)
-         * @see 
org.apache.pig.impl.logicalLayer.LOVisitor#visit(org.apache.pig.impl.logicalLayer.LOCast)
-         */
         @Override
         protected void visit(LOCast cast) throws VisitorException {
             casts.add(cast);

Modified: 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidatorNoSchema.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidatorNoSchema.java?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidatorNoSchema.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/TestTypeCheckingValidatorNoSchema.java
 Mon Jan  4 22:20:03 2010
@@ -28,7 +28,7 @@
 import org.apache.pig.impl.plan.CompilationMessageCollector;
 import org.apache.pig.impl.plan.PlanValidationException;
 import org.apache.pig.impl.util.MultiMap;
-import org.apache.pig.backend.hadoop.datastorage.HDataStorage;
+import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.pig.builtin.PigStorage;
 import org.apache.pig.data.DataType;
 import org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema ;
@@ -136,8 +136,6 @@
         // Create outer plan
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
 
         // set schemas
@@ -233,8 +231,6 @@
         // Create outer plan
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
 
         // set schemas
@@ -326,8 +322,6 @@
         printCurrentMethodName();
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
 
         // set schemas
@@ -363,8 +357,6 @@
         // Create outer plan
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
 
         // set schemas
@@ -445,7 +437,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, new HDataStorage(new Properties())) ;
+                                  ConfigurationUtil.toConfiguration(new 
Properties())) ;
 
         // set schemas
         load1.setEnforcedSchema(null) ;
@@ -509,7 +501,7 @@
         LOLoad load1 = new LOLoad(plan,
                                   genNewOperatorKey(),
                                   new FileSpec("pi", new FuncSpec(pigStorage)),
-                                  null, new HDataStorage(new Properties())) ;
+                                  ConfigurationUtil.toConfiguration(new 
Properties())) ;
 
         // set schemas
         load1.setEnforcedSchema(null) ;
@@ -570,8 +562,6 @@
         printCurrentMethodName();
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
         LOLoad load2 = genDummyLOLoad(plan) ;
 
@@ -621,8 +611,6 @@
         printCurrentMethodName();
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
         LOLoad load2 = genDummyLOLoad(plan) ;
 
@@ -664,8 +652,6 @@
         printCurrentMethodName();
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
         LOLoad load2 = genDummyLOLoad(plan) ;
 
@@ -766,8 +752,6 @@
         printCurrentMethodName();
         LogicalPlan plan = new LogicalPlan() ;
 
-        String pigStorage = PigStorage.class.getName() ;
-
         LOLoad load1 = genDummyLOLoad(plan) ;
         LOLoad load2 = genDummyLOLoad(plan) ;
 

Modified: 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/TypeCheckingTestUtil.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/TypeCheckingTestUtil.java?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/TypeCheckingTestUtil.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/TypeCheckingTestUtil.java
 Mon Jan  4 22:20:03 2010
@@ -18,36 +18,33 @@
 
 package org.apache.pig.test.utils;
 
-import org.apache.hadoop.hdfs.server.common.HdfsConstants.NodeType;
-import org.apache.pig.backend.datastorage.DataStorage;
-import org.apache.pig.backend.hadoop.datastorage.HDataStorage;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Properties;
+
 import org.apache.pig.FuncSpec;
-import org.apache.pig.impl.logicalLayer.LogicalPlan;
+import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
+import org.apache.pig.builtin.PigStorage;
+import org.apache.pig.impl.io.FileSpec;
 import org.apache.pig.impl.logicalLayer.LOLoad;
-import org.apache.pig.impl.plan.OperatorKey;
+import org.apache.pig.impl.logicalLayer.LogicalPlan;
 import org.apache.pig.impl.logicalLayer.schema.Schema;
-import org.apache.pig.impl.plan.NodeIdGenerator;
 import org.apache.pig.impl.plan.CompilationMessageCollector;
-import org.apache.pig.impl.io.FileSpec;
-import org.apache.pig.builtin.PigStorage;
+import org.apache.pig.impl.plan.NodeIdGenerator;
+import org.apache.pig.impl.plan.OperatorKey;
 import org.apache.pig.test.TypeGraphPrinter;
 
-import java.util.Iterator;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Properties;
-import java.io.IOException;
-
 public class TypeCheckingTestUtil {
 
     public static LOLoad genDummyLOLoad(LogicalPlan plan)  {
         String pigStorage = PigStorage.class.getName() ;
-        DataStorage dfs = new HDataStorage(new Properties());
         try {
             LOLoad load = new LOLoad(plan,
                                       genNewOperatorKey(),
                                       new FileSpec("pi", new 
FuncSpec(pigStorage)),
-                                      null, dfs) ;
+                                      ConfigurationUtil.toConfiguration(new 
Properties())) ;
             return load ;
         } catch (IOException e) {
             throw new AssertionError("This cannot happen") ;

Modified: 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/dotGraph/LogicalPlanLoader.java
URL: 
http://svn.apache.org/viewvc/hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/dotGraph/LogicalPlanLoader.java?rev=895802&r1=895801&r2=895802&view=diff
==============================================================================
--- 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/dotGraph/LogicalPlanLoader.java
 (original)
+++ 
hadoop/pig/branches/load-store-redesign/test/org/apache/pig/test/utils/dotGraph/LogicalPlanLoader.java
 Mon Jan  4 22:20:03 2010
@@ -18,21 +18,30 @@
 
 package org.apache.pig.test.utils.dotGraph;
 
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.util.Map;
+
 import org.apache.pig.FuncSpec;
-import org.apache.pig.impl.logicalLayer.*;
-import org.apache.pig.impl.logicalLayer.schema.Schema;
-import org.apache.pig.impl.logicalLayer.parser.QueryParser ;
-import org.apache.pig.impl.logicalLayer.parser.ParseException ;
-import org.apache.pig.impl.logicalLayer.FrontendException ;
-import org.apache.pig.impl.io.FileSpec;
 import org.apache.pig.builtin.PigStorage;
 import org.apache.pig.data.DataType;
-
-import java.io.IOException;
-import java.io.ByteArrayInputStream;
-import java.util.Map;
-import java.util.regex.Pattern;
-import java.util.regex.Matcher;
+import org.apache.pig.impl.io.FileSpec;
+import org.apache.pig.impl.logicalLayer.FrontendException;
+import org.apache.pig.impl.logicalLayer.LOCogroup;
+import org.apache.pig.impl.logicalLayer.LOCross;
+import org.apache.pig.impl.logicalLayer.LODistinct;
+import org.apache.pig.impl.logicalLayer.LOFilter;
+import org.apache.pig.impl.logicalLayer.LOForEach;
+import org.apache.pig.impl.logicalLayer.LOLoad;
+import org.apache.pig.impl.logicalLayer.LOSort;
+import org.apache.pig.impl.logicalLayer.LOSplit;
+import org.apache.pig.impl.logicalLayer.LOSplitOutput;
+import org.apache.pig.impl.logicalLayer.LOUnion;
+import org.apache.pig.impl.logicalLayer.LogicalOperator;
+import org.apache.pig.impl.logicalLayer.LogicalPlan;
+import org.apache.pig.impl.logicalLayer.parser.ParseException;
+import org.apache.pig.impl.logicalLayer.parser.QueryParser;
+import org.apache.pig.impl.logicalLayer.schema.Schema;
 
 
 public class LogicalPlanLoader
@@ -95,7 +104,7 @@
         FileSpec fileSpec = new FileSpec("pi",
                                          new 
FuncSpec(PigStorage.class.getName())) ;
         try {
-            load = new LOLoad(plan, getKey(node.attributes), fileSpec, null, 
null) ;
+            load = new LOLoad(plan, getKey(node.attributes), fileSpec, null) ;
             fillSchema(load, node.attributes) ;
         }
         catch (IOException ioe) {


Reply via email to