You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by Apache Wiki <wi...@apache.org> on 2010/05/15 08:56:58 UTC
[Pig Wiki] Trivial Update of "LoadStoreMigrationGuide" by newacct
Dear Wiki user,
You have subscribed to a wiki page or wiki category on "Pig Wiki" for change notification.
The "LoadStoreMigrationGuide" page has been changed by newacct.
http://wiki.apache.org/pig/LoadStoreMigrationGuide?action=diff&rev1=38&rev2=39
--------------------------------------------------
long end = Long.MAX_VALUE;
private byte recordDel = '\n';
private byte fieldDel = '\t';
- private ByteArrayOutputStream mBuf = null;
+ private ByteArrayOutputStream mBuf;
- private ArrayList<Object> mProtoTuple = null;
+ private ArrayList<Object> mProtoTuple;
private static final String UTF8 = "UTF-8";
public SimpleTextLoader() {
@@ -96, +96 @@
case 'x':
case 'u':
this.fieldDel =
- Integer.valueOf(delimiter.substring(2)).byteValue();
+ (byte)Integer.parseInt(delimiter.substring(2));
break;
default:
throw new RuntimeException("Unknown delimiter " + delimiter);
}
} else {
- throw new RuntimeException("PigStorage delimeter must be a single character");
+ throw new RuntimeException("PigStorage delimiter must be a single character");
}
}
@@ -141, +141 @@
this.end = end;
// Since we are not block aligned we throw away the first
- // record and cound on a different instance to read it
+ // record and count on a different instance to read it
if (offset != 0) {
getNext();
}
@@ -179, +179 @@
=== New Implementation ===
{{{
public class SimpleTextLoader extends LoadFunc {
- protected RecordReader in = null;
+ protected RecordReader in;
private byte fieldDel = '\t';
- private ArrayList<Object> mProtoTuple = null;
+ private ArrayList<Object> mProtoTuple;
private TupleFactory mTupleFactory = TupleFactory.getInstance();
private static final int BUFFER_SIZE = 1024;
@@ -207, +207 @@
case 'x':
fieldDel =
- Integer.valueOf(delimiter.substring(2), 16).byteValue();
+ (byte)Integer.parseInt(delimiter.substring(2), 16);
break;
case 'u':
this.fieldDel =
- Integer.valueOf(delimiter.substring(2)).byteValue();
+ (byte)Integer.parseInt(delimiter.substring(2));
break;
default:
throw new RuntimeException("Unknown delimiter " + delimiter);
}
} else {
- throw new RuntimeException("PigStorage delimeter must be a single character");
+ throw new RuntimeException("PigStorage delimiter must be a single character");
}
}
@@ -313, +313 @@
case 'x':
case 'u':
this.fieldDel =
- Integer.valueOf(delimiter.substring(2)).byteValue();
+ (byte)Integer.parseInt(delimiter.substring(2));
break;
default:
throw new RuntimeException("Unknown delimiter " + delimiter);
}
} else {
- throw new RuntimeException("PigStorage delimeter must be a single character");
+ throw new RuntimeException("PigStorage delimiter must be a single character");
}
}
@@ -496, +496 @@
case 'x':
fieldDel =
- Integer.valueOf(delimiter.substring(2), 16).byteValue();
+ (byte)Integer.parseInt(delimiter.substring(2), 16);
break;
case 'u':
this.fieldDel =
- Integer.valueOf(delimiter.substring(2)).byteValue();
+ (byte)Integer.parseInt(delimiter.substring(2));
break;
default:
throw new RuntimeException("Unknown delimiter " + delimiter);
}
} else {
- throw new RuntimeException("PigStorage delimeter must be a single character");
+ throw new RuntimeException("PigStorage delimiter must be a single character");
}
}