You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by dv...@apache.org on 2012/04/06 22:38:11 UTC
svn commit: r1310576 - in /pig/branches/branch-0.9: CHANGES.txt
contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/PigStorageSchema.java
Author: dvryaboy
Date: Fri Apr 6 20:38:11 2012
New Revision: 1310576
URL: http://svn.apache.org/viewvc?rev=1310576&view=rev
Log:
PIG-2555: PigStorageSchema initializes schema and PigContext for every tuple
Modified:
pig/branches/branch-0.9/CHANGES.txt
pig/branches/branch-0.9/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/PigStorageSchema.java
Modified: pig/branches/branch-0.9/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/CHANGES.txt?rev=1310576&r1=1310575&r2=1310576&view=diff
==============================================================================
--- pig/branches/branch-0.9/CHANGES.txt (original)
+++ pig/branches/branch-0.9/CHANGES.txt Fri Apr 6 20:38:11 2012
@@ -22,6 +22,8 @@ Release 0.9.3 - Unreleased
IMPROVEMENTS
+PIG-2555: PigStorageSchema initializes schema and PigContext for every tuple (rangadi via dvryaboy)
+
PIG-2619: HBaseStorage constructs a Scan with cacheBlocks = false
BUG FIXES
Modified: pig/branches/branch-0.9/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/PigStorageSchema.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.9/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/PigStorageSchema.java?rev=1310576&r1=1310575&r2=1310576&view=diff
==============================================================================
--- pig/branches/branch-0.9/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/PigStorageSchema.java (original)
+++ pig/branches/branch-0.9/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/PigStorageSchema.java Fri Apr 6 20:38:11 2012
@@ -69,16 +69,18 @@ public class PigStorageSchema extends Pi
if ( caster == null) {
caster = getLoadCaster();
- }
- if (signature != null) {
- Properties p = UDFContext.getUDFContext().getUDFProperties(this.getClass(),
- new String[] {signature});
- String serializedSchema = p.getProperty(signature+".schema");
- if (serializedSchema == null) return tup;
- try {
- schema = new ResourceSchema(Utils.getSchemaFromString(serializedSchema));
- } catch (ParserException e) {
- mLog.error("Unable to parse serialized schema " + serializedSchema, e);
+
+ if (signature != null) {
+ Properties p = UDFContext.getUDFContext().getUDFProperties(this.getClass(),
+ new String[] {signature});
+ String serializedSchema = p.getProperty(signature+".schema");
+ if (serializedSchema != null) {
+ try {
+ schema = new ResourceSchema(Utils.getSchemaFromString(serializedSchema));
+ } catch (ParserException e) {
+ mLog.error("Unable to parse serialized schema " + serializedSchema, e);
+ }
+ }
}
}