incubator-crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject git commit: CRUNCH-134: Move CrunchRuntimeException to org.apache.crunch
Date Tue, 18 Dec 2012 19:43:36 GMT
Updated Branches:
  refs/heads/master ac317a185 -> 29de385be


CRUNCH-134: Move CrunchRuntimeException to org.apache.crunch


Project: http://git-wip-us.apache.org/repos/asf/incubator-crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-crunch/commit/29de385b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-crunch/tree/29de385b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-crunch/diff/29de385b

Branch: refs/heads/master
Commit: 29de385be69738de3acd3369216c4839620689c7
Parents: ac317a1
Author: Josh Wills <jwills@apache.org>
Authored: Tue Dec 18 09:22:28 2012 -0800
Committer: Josh Wills <jwills@apache.org>
Committed: Tue Dec 18 09:43:29 2012 -0800

----------------------------------------------------------------------
 .../org/apache/crunch/io/hbase/HBaseTarget.java    |    2 +-
 .../org/apache/crunch/lib/join/MapsideJoinIT.java  |    2 +-
 .../org/apache/crunch/CrunchRuntimeException.java  |   54 +++++++++++++++
 .../java/org/apache/crunch/impl/mr/MRPipeline.java |    2 +-
 .../crunch/impl/mr/emit/MultipleOutputEmitter.java |    2 +-
 .../apache/crunch/impl/mr/emit/OutputEmitter.java  |    2 +-
 .../apache/crunch/impl/mr/run/CrunchMapper.java    |    1 +
 .../apache/crunch/impl/mr/run/CrunchReducer.java   |    1 +
 .../crunch/impl/mr/run/CrunchRuntimeException.java |   43 ------------
 .../crunch/impl/mr/run/CrunchTaskContext.java      |    1 +
 .../java/org/apache/crunch/impl/mr/run/RTNode.java |    1 +
 .../org/apache/crunch/lib/join/MapsideJoin.java    |    2 +-
 .../crunch/materialize/MaterializableIterable.java |    2 +-
 .../main/java/org/apache/crunch/types/PTypes.java  |    2 +-
 .../main/java/org/apache/crunch/types/Protos.java  |    2 +-
 .../java/org/apache/crunch/types/TupleFactory.java |    2 +-
 .../apache/crunch/types/avro/AvroDeepCopier.java   |    2 +-
 .../types/writable/GenericArrayWritable.java       |    2 +-
 .../crunch/types/writable/WritableDeepCopier.java  |    2 +-
 .../java/org/apache/crunch/util/DistCache.java     |    2 +-
 20 files changed, 72 insertions(+), 57 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
----------------------------------------------------------------------
diff --git a/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java b/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
index b8b9c14..35a74fa 100644
--- a/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
+++ b/crunch-hbase/src/main/java/org/apache/crunch/io/hbase/HBaseTarget.java
@@ -20,9 +20,9 @@ package org.apache.crunch.io.hbase;
 import java.io.IOException;
 
 import org.apache.commons.lang.builder.HashCodeBuilder;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.SourceTarget;
 import org.apache.crunch.hadoop.mapreduce.lib.output.CrunchMultipleOutputs;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.io.MapReduceTarget;
 import org.apache.crunch.io.OutputHandler;
 import org.apache.crunch.types.PType;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
----------------------------------------------------------------------
diff --git a/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java b/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
index 297680e..9147baf 100644
--- a/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
+++ b/crunch/src/it/java/org/apache/crunch/lib/join/MapsideJoinIT.java
@@ -24,6 +24,7 @@ import java.io.IOException;
 import java.util.Collections;
 import java.util.List;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.MapFn;
 import org.apache.crunch.PTable;
 import org.apache.crunch.Pair;
@@ -31,7 +32,6 @@ import org.apache.crunch.Pipeline;
 import org.apache.crunch.fn.FilterFns;
 import org.apache.crunch.impl.mem.MemPipeline;
 import org.apache.crunch.impl.mr.MRPipeline;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.test.TemporaryPath;
 import org.apache.crunch.test.TemporaryPaths;
 import org.apache.crunch.types.writable.Writables;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java b/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java
new file mode 100644
index 0000000..044f600
--- /dev/null
+++ b/crunch/src/main/java/org/apache/crunch/CrunchRuntimeException.java
@@ -0,0 +1,54 @@
+/**
+ * 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.crunch;
+
+/**
+ * A {@code RuntimeException} implementation that includes some additional options
+ * for the Crunch execution engine to track reporting status. Clients may
+ * use instances of this class in their own {@code DoFn} implementations.
+ */
+public class CrunchRuntimeException extends RuntimeException {
+
+  private boolean logged = false;
+
+  public CrunchRuntimeException(String msg) {
+    super(msg);
+  }
+
+  public CrunchRuntimeException(Exception e) {
+    super(e);
+  }
+
+  public CrunchRuntimeException(String msg, Exception e) {
+    super(msg, e);
+  }
+
+  /**
+   * Returns true if this exception was written to the debug logs.
+   */
+  public boolean wasLogged() {
+    return logged;
+  }
+
+  /**
+   * Indicate that this exception has been written to the debug logs.
+   */
+  public void markLogged() {
+    this.logged = true;
+  }
+}

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java b/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
index 60950f3..40c5863 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/MRPipeline.java
@@ -24,6 +24,7 @@ import java.util.Set;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.MapFn;
 import org.apache.crunch.PCollection;
 import org.apache.crunch.PTable;
@@ -42,7 +43,6 @@ import org.apache.crunch.impl.mr.collect.UnionCollection;
 import org.apache.crunch.impl.mr.collect.UnionTable;
 import org.apache.crunch.impl.mr.exec.MRExecutor;
 import org.apache.crunch.impl.mr.plan.MSCRPlanner;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.impl.mr.run.RuntimeParameters;
 import org.apache.crunch.io.At;
 import org.apache.crunch.io.ReadableSourceTarget;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
index e068e3c..d271112 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/MultipleOutputEmitter.java
@@ -19,8 +19,8 @@ package org.apache.crunch.impl.mr.emit;
 
 import java.io.IOException;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.Emitter;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.types.Converter;
 import org.apache.crunch.hadoop.mapreduce.lib.output.CrunchMultipleOutputs;
 

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
index 88990c2..bc3ae0d 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/emit/OutputEmitter.java
@@ -19,8 +19,8 @@ package org.apache.crunch.impl.mr.emit;
 
 import java.io.IOException;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.Emitter;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.types.Converter;
 import org.apache.hadoop.mapreduce.TaskInputOutputContext;
 

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
index 2de1567..70f0b01 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchMapper.java
@@ -22,6 +22,7 @@ import java.util.List;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.hadoop.mapreduce.Mapper;
 
 public class CrunchMapper extends Mapper<Object, Object, Object, Object> {

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
index 89fbd26..12caa86 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchReducer.java
@@ -22,6 +22,7 @@ import java.util.List;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.hadoop.mapreduce.Reducer;
 
 public class CrunchReducer extends Reducer<Object, Object, Object, Object> {

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
deleted file mode 100644
index 72e939f..0000000
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchRuntimeException.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/**
- * 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.crunch.impl.mr.run;
-
-public class CrunchRuntimeException extends RuntimeException {
-
-  private boolean logged = false;
-
-  public CrunchRuntimeException(String msg) {
-    super(msg);
-  }
-
-  public CrunchRuntimeException(Exception e) {
-    super(e);
-  }
-
-  public CrunchRuntimeException(String msg, Exception e) {
-    super(msg, e);
-  }
-
-  public boolean wasLogged() {
-    return logged;
-  }
-
-  public void markLogged() {
-    this.logged = true;
-  }
-}

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
index 4ba8bad..3846e36 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/CrunchTaskContext.java
@@ -20,6 +20,7 @@ package org.apache.crunch.impl.mr.run;
 import java.io.IOException;
 import java.util.List;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.impl.mr.plan.PlanningParameters;
 import org.apache.crunch.util.DistCache;
 import org.apache.hadoop.conf.Configuration;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java b/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
index 1f5124c..ead1d9e 100644
--- a/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
+++ b/crunch/src/main/java/org/apache/crunch/impl/mr/run/RTNode.java
@@ -22,6 +22,7 @@ import java.util.List;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.DoFn;
 import org.apache.crunch.Emitter;
 import org.apache.crunch.impl.mr.emit.IntermediateEmitter;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java b/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
index 0ca1ab3..1acbf2d 100644
--- a/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
+++ b/crunch/src/main/java/org/apache/crunch/lib/join/MapsideJoin.java
@@ -19,12 +19,12 @@ package org.apache.crunch.lib.join;
 
 import java.io.IOException;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.DoFn;
 import org.apache.crunch.Emitter;
 import org.apache.crunch.PTable;
 import org.apache.crunch.Pair;
 import org.apache.crunch.impl.mr.MRPipeline;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.io.ReadableSourceTarget;
 import org.apache.crunch.io.impl.SourcePathTargetImpl;
 import org.apache.crunch.types.PType;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
b/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
index 3830616..2d6c573 100644
--- a/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
+++ b/crunch/src/main/java/org/apache/crunch/materialize/MaterializableIterable.java
@@ -22,8 +22,8 @@ import java.util.Iterator;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.Pipeline;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.crunch.io.ReadableSourceTarget;
 
 public class MaterializableIterable<E> implements Iterable<E> {

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/PTypes.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/PTypes.java b/crunch/src/main/java/org/apache/crunch/types/PTypes.java
index 9533872..1f87874 100644
--- a/crunch/src/main/java/org/apache/crunch/types/PTypes.java
+++ b/crunch/src/main/java/org/apache/crunch/types/PTypes.java
@@ -20,8 +20,8 @@ package org.apache.crunch.types;
 import java.math.BigInteger;
 import java.nio.ByteBuffer;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.MapFn;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.hadoop.util.ReflectionUtils;
 import org.apache.thrift.TBase;
 import org.apache.thrift.TDeserializer;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/Protos.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/Protos.java b/crunch/src/main/java/org/apache/crunch/types/Protos.java
index 2de1c11..4cd5068 100644
--- a/crunch/src/main/java/org/apache/crunch/types/Protos.java
+++ b/crunch/src/main/java/org/apache/crunch/types/Protos.java
@@ -20,10 +20,10 @@ package org.apache.crunch.types;
 import java.util.Iterator;
 import java.util.List;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.DoFn;
 import org.apache.crunch.Emitter;
 import org.apache.crunch.MapFn;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 import org.apache.hadoop.util.ReflectionUtils;
 
 import com.google.common.base.Splitter;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java b/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
index 69fbc92..73b47de 100644
--- a/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
+++ b/crunch/src/main/java/org/apache/crunch/types/TupleFactory.java
@@ -21,12 +21,12 @@ import java.io.Serializable;
 import java.lang.reflect.Constructor;
 import java.util.Map;
 
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.Pair;
 import org.apache.crunch.Tuple;
 import org.apache.crunch.Tuple3;
 import org.apache.crunch.Tuple4;
 import org.apache.crunch.TupleN;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
 
 import com.google.common.collect.Maps;
 

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java b/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
index 4b02fc6..2deeddb 100644
--- a/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
+++ b/crunch/src/main/java/org/apache/crunch/types/avro/AvroDeepCopier.java
@@ -33,7 +33,7 @@ import org.apache.avro.io.DecoderFactory;
 import org.apache.avro.io.EncoderFactory;
 import org.apache.avro.specific.SpecificDatumReader;
 import org.apache.avro.specific.SpecificDatumWriter;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.types.DeepCopier;
 import org.apache.hadoop.conf.Configuration;
 

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
b/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
index 8e2ec6d..79c93be 100644
--- a/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
+++ b/crunch/src/main/java/org/apache/crunch/types/writable/GenericArrayWritable.java
@@ -23,7 +23,7 @@ import java.io.IOException;
 import java.util.Arrays;
 
 import org.apache.commons.lang.builder.HashCodeBuilder;
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.WritableFactories;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
b/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
index ae4614d..84e22e3 100644
--- a/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
+++ b/crunch/src/main/java/org/apache/crunch/types/writable/WritableDeepCopier.java
@@ -23,7 +23,7 @@ import java.io.DataInput;
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
 
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.crunch.types.DeepCopier;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.Writable;

http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/29de385b/crunch/src/main/java/org/apache/crunch/util/DistCache.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/util/DistCache.java b/crunch/src/main/java/org/apache/crunch/util/DistCache.java
index 20675d2..891cc6c 100644
--- a/crunch/src/main/java/org/apache/crunch/util/DistCache.java
+++ b/crunch/src/main/java/org/apache/crunch/util/DistCache.java
@@ -26,7 +26,7 @@ import java.net.URL;
 import java.net.URLDecoder;
 import java.util.Enumeration;
 
-import org.apache.crunch.impl.mr.run.CrunchRuntimeException;
+import org.apache.crunch.CrunchRuntimeException;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.filecache.DistributedCache;
 import org.apache.hadoop.fs.FileSystem;


Mime
View raw message