Author: hashutosh
Date: Tue Jun 21 21:31:06 2011
New Revision: 1138193
URL: http://svn.apache.org/viewvc?rev=1138193&view=rev
Log:
HCATALOG-35: HCatalog fails to compile with Pig 0.9
Modified:
incubator/hcatalog/trunk/CHANGES.txt
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatBaseStorer.java
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatEximStorer.java
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatStorer.java
Modified: incubator/hcatalog/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/CHANGES.txt?rev=1138193&r1=1138192&r2=1138193&view=diff
==============================================================================
--- incubator/hcatalog/trunk/CHANGES.txt (original)
+++ incubator/hcatalog/trunk/CHANGES.txt Tue Jun 21 21:31:06 2011
@@ -15,6 +15,8 @@ Trunk (unreleased changes)
IMPROVEMENTS
+ HCAT-35. HCatalog fails to compile with Pig 0.9 (hashutosh)
+
HCAT-47. Topic prefix for the message bus should be configurable
(hashutosh)
HCAT-39. Lazily create connection for Message bus (hashutosh)
Modified:
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatBaseStorer.java
URL:
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatBaseStorer.java?rev=1138193&r1=1138192&r2=1138193&view=diff
==============================================================================
---
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatBaseStorer.java
(original)
+++
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatBaseStorer.java
Tue Jun 21 21:31:06 2011
@@ -45,7 +45,6 @@ import org.apache.pig.data.DataBag;
import org.apache.pig.data.DataType;
import org.apache.pig.data.Tuple;
import org.apache.pig.impl.logicalLayer.FrontendException;
-import org.apache.pig.impl.logicalLayer.parser.ParseException;
import org.apache.pig.impl.logicalLayer.schema.Schema;
import org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema;
import org.apache.pig.impl.util.ObjectSerializer;
@@ -70,7 +69,7 @@ public abstract class HCatBaseStorer ext
protected static final String PIG_SCHEMA = "hcat.pig.store.schema";
protected String sign;
- public HCatBaseStorer(String partSpecs, String schema) throws
ParseException, FrontendException {
+ public HCatBaseStorer(String partSpecs, String schema) throws Exception {
partitions = new HashMap<String, String>();
if(partSpecs != null && !partSpecs.trim().isEmpty()){
Modified:
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatEximStorer.java
URL:
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatEximStorer.java?rev=1138193&r1=1138192&r2=1138193&view=diff
==============================================================================
---
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatEximStorer.java
(original)
+++
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatEximStorer.java
Tue Jun 21 21:31:06 2011
@@ -38,7 +38,6 @@ import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.mapreduce.OutputFormat;
import org.apache.pig.ResourceSchema;
import org.apache.pig.impl.logicalLayer.FrontendException;
-import org.apache.pig.impl.logicalLayer.parser.ParseException;
import org.apache.pig.impl.logicalLayer.schema.Schema;
import org.apache.pig.impl.util.ObjectSerializer;
import org.apache.pig.impl.util.UDFContext;
@@ -54,17 +53,16 @@ public class HCatEximStorer extends HCat
private final String outputLocation;
- public HCatEximStorer(String outputLocation) throws FrontendException,
ParseException {
+ public HCatEximStorer(String outputLocation) throws Exception {
this(outputLocation, null, null);
}
- public HCatEximStorer(String outputLocation, String partitionSpec) throws
FrontendException,
- ParseException {
+ public HCatEximStorer(String outputLocation, String partitionSpec) throws
Exception {
this(outputLocation, partitionSpec, null);
}
public HCatEximStorer(String outputLocation, String partitionSpec, String
schema)
- throws FrontendException, ParseException {
+ throws Exception {
super(partitionSpec, schema);
this.outputLocation = outputLocation;
LOG.debug("HCatEximStorer called");
Modified:
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatStorer.java
URL:
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatStorer.java?rev=1138193&r1=1138192&r2=1138193&view=diff
==============================================================================
--- incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatStorer.java
(original)
+++ incubator/hcatalog/trunk/src/java/org/apache/hcatalog/pig/HCatStorer.java
Tue Jun 21 21:31:06 2011
@@ -34,7 +34,6 @@ import org.apache.hcatalog.mapreduce.HCa
import org.apache.pig.PigException;
import org.apache.pig.ResourceSchema;
import org.apache.pig.impl.logicalLayer.FrontendException;
-import org.apache.pig.impl.logicalLayer.parser.ParseException;
import org.apache.pig.impl.logicalLayer.schema.Schema;
import org.apache.pig.impl.util.ObjectSerializer;
import org.apache.pig.impl.util.UDFContext;
@@ -50,15 +49,15 @@ public class HCatStorer extends HCatBase
*
*/
- public HCatStorer(String partSpecs, String schema) throws ParseException,
FrontendException {
+ public HCatStorer(String partSpecs, String schema) throws Exception {
super(partSpecs, schema);
}
- public HCatStorer(String partSpecs) throws ParseException, FrontendException
{
+ public HCatStorer(String partSpecs) throws Exception {
this(partSpecs, null);
}
- public HCatStorer() throws FrontendException, ParseException{
+ public HCatStorer() throws Exception{
this(null,null);
}