pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cheol...@apache.org
Subject svn commit: r1581399 - in /pig/trunk: ./ src/org/apache/pig/backend/hadoop/executionengine/ src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/ test/org/apache/pig/test/
Date Tue, 25 Mar 2014 16:12:13 GMT
Author: cheolsoo
Date: Tue Mar 25 16:12:12 2014
New Revision: 1581399

URL: http://svn.apache.org/r1581399
Log:
PIG-3449: Move JobCreationException to org.apache.pig.backend.hadoop.executionengine (cheolsoo)

Added:
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/JobCreationException.java
Removed:
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobCreationException.java
Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
    pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NativeMapReduceOper.java
    pig/trunk/test/org/apache/pig/test/TestJobSubmission.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1581399&r1=1581398&r2=1581399&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Mar 25 16:12:12 2014
@@ -30,6 +30,8 @@ PIG-2207: Support custom counters for ag
 
 IMPROVEMENTS
 
+PIG-3449: Move JobCreationException to org.apache.pig.backend.hadoop.executionengine (cheolsoo)
+
 PIG-3802: Fix TestBlackAndWhitelistValidator failures (prkommireddi)
 
 PIG-3765: Ability to disable Pig commands and operators (prkommireddi)

Added: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/JobCreationException.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/JobCreationException.java?rev=1581399&view=auto
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/JobCreationException.java
(added)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/JobCreationException.java
Tue Mar 25 16:12:12 2014
@@ -0,0 +1,160 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.pig.backend.hadoop.executionengine;
+
+import org.apache.pig.impl.logicalLayer.FrontendException;
+
+public class JobCreationException extends FrontendException{
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * Create a new JobCreationException with null as the error message.
+     */
+    public JobCreationException() {
+        super();
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     */
+    public JobCreationException(String message) {
+        super(message);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified cause.
+     *
+     * @param cause - The cause (which is saved for later retrieval by the <link>Throwable.getCause()</link>
method) indicating the source of this exception. A null value is permitted, and indicates
that the cause is nonexistent or unknown.
+     */
+    public JobCreationException(Throwable cause) {
+        super(cause);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param cause - The cause (which is saved for later retrieval by the <link>Throwable.getCause()</link>
method) indicating the source of this exception. A null value is permitted, and indicates
that the cause is nonexistent or unknown.
+     */
+    public JobCreationException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     */
+    public JobCreationException(String message, int errCode) {
+        super(message, errCode);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param cause - The cause (which is saved for later retrieval by the <link>Throwable.getCause()</link>
method) indicating the source of this exception. A null value is permitted, and indicates
that the cause is nonexistent or unknown.
+     */
+    public JobCreationException(String message, int errCode, Throwable cause) {
+        super(message, errCode, cause);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param errSrc - The error source
+     */
+    public JobCreationException(String message, int errCode, byte errSrc) {
+        super(message, errCode, errSrc);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param errSrc - The error source
+     * @param cause - The cause (which is saved for later retrieval by the <link>Throwable.getCause()</link>
method) indicating the source of this exception. A null value is permitted, and indicates
that the cause is nonexistent or unknown.
+     */
+    public JobCreationException(String message, int errCode, byte errSrc,
+            Throwable cause) {
+        super(message, errCode, errSrc, cause);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param retry - If the exception is retriable or not
+     */
+    public JobCreationException(String message, int errCode, boolean retry) {
+        super(message, errCode, retry);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param errSrc - The error source
+     * @param retry - If the exception is retriable or not
+     */
+    public JobCreationException(String message, int errCode, byte errSrc,
+            boolean retry) {
+        super(message, errCode, errSrc, retry);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message, error code, error source,
retriable or not, detalied message for the developer and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param errSrc - The error source
+     * @param retry - If the exception is retriable or not
+     * @param detailedMsg - The detailed message shown to the developer
+     */
+    public JobCreationException(String message, int errCode, byte errSrc,
+            boolean retry, String detailedMsg) {
+        super(message, errCode, errSrc, retry, detailedMsg);
+    }
+
+    /**
+     * Create a new JobCreationException with the specified message, error code, error source,
retriable or not, detalied message for the developer and cause.
+     *
+     * @param message - The error message (which is saved for later retrieval by the <link>Throwable.getMessage()</link>
method) shown to the user
+     * @param errCode - The error code shown to the user
+     * @param errSrc - The error source
+     * @param retry - If the exception is retriable or not
+     * @param detailedMsg - The detailed message shown to the developer
+     * @param cause - The cause (which is saved for later retrieval by the <link>Throwable.getCause()</link>
method) indicating the source of this exception. A null value is permitted, and indicates
that the cause is nonexistent or unknown.
+     */
+    public JobCreationException(String message, int errCode, byte errSrc,
+            boolean retry, String detailedMsg, Throwable cause) {
+        super(message, errCode, errSrc, retry, detailedMsg, cause);
+    }
+
+}
+

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java?rev=1581399&r1=1581398&r2=1581399&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
(original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/JobControlCompiler.java
Tue Mar 25 16:12:12 2014
@@ -68,6 +68,7 @@ import org.apache.pig.StoreFuncInterface
 import org.apache.pig.backend.executionengine.ExecException;
 import org.apache.pig.backend.hadoop.HDataType;
 import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
+import org.apache.pig.backend.hadoop.executionengine.JobCreationException;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SecondaryKeyPartitioner;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SkewedPartitioner;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner;

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java?rev=1581399&r1=1581398&r2=1581399&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
(original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/MapReduceLauncher.java
Tue Mar 25 16:12:12 2014
@@ -49,6 +49,7 @@ import org.apache.pig.backend.BackendExc
 import org.apache.pig.backend.executionengine.ExecException;
 import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
 import org.apache.pig.backend.hadoop.executionengine.HExecutionEngine;
+import org.apache.pig.backend.hadoop.executionengine.JobCreationException;
 import org.apache.pig.backend.hadoop.executionengine.Launcher;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler.LastInputStreamingOptimizer;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter;

Modified: pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NativeMapReduceOper.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NativeMapReduceOper.java?rev=1581399&r1=1581398&r2=1581399&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NativeMapReduceOper.java
(original)
+++ pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NativeMapReduceOper.java
Tue Mar 25 16:12:12 2014
@@ -20,6 +20,7 @@ package org.apache.pig.backend.hadoop.ex
 import java.util.Arrays;
 
 import org.apache.hadoop.util.RunJar;
+import org.apache.pig.backend.hadoop.executionengine.JobCreationException;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.MROpPlanVisitor;
 import org.apache.pig.impl.plan.OperatorKey;
 import org.apache.pig.impl.plan.VisitorException;

Modified: pig/trunk/test/org/apache/pig/test/TestJobSubmission.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/TestJobSubmission.java?rev=1581399&r1=1581398&r2=1581399&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/TestJobSubmission.java (original)
+++ pig/trunk/test/org/apache/pig/test/TestJobSubmission.java Tue Mar 25 16:12:12 2014
@@ -40,8 +40,8 @@ import org.apache.pig.ExecType;
 import org.apache.pig.PigServer;
 import org.apache.pig.backend.executionengine.ExecException;
 import org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil;
+import org.apache.pig.backend.hadoop.executionengine.JobCreationException;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler;
-import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobCreationException;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper;
 import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.MROperPlan;
 import org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator;



Mime
View raw message