Author: olga
Date: Fri Dec 4 17:35:13 2009
New Revision: 887285
URL: http://svn.apache.org/viewvc?rev=887285&view=rev
Log:
PIG-1126: updated signiture for fieldsToRead
Modified:
hadoop/pig/branches/branch-0.6/contrib/CHANGES.txt
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/RegExLoader.java
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/SequenceFileLoader.java
Modified: hadoop/pig/branches/branch-0.6/contrib/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/pig/branches/branch-0.6/contrib/CHANGES.txt?rev=887285&r1=887284&r2=887285&view=diff
==============================================================================
--- hadoop/pig/branches/branch-0.6/contrib/CHANGES.txt (original)
+++ hadoop/pig/branches/branch-0.6/contrib/CHANGES.txt Fri Dec 4 17:35:13 2009
@@ -1,3 +1,4 @@
+PIG-1126: updated loaders with new signiture of fieldsToRead (olgan)
PIG-1015: [piggybank] DateExtractor should take into account timezones
(dryaboy via olgan)
PIG-911: Added SequenceFileLoader (dryaboy via gates)
Modified:
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/RegExLoader.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/RegExLoader.java?rev=887285&r1=887284&r2=887285&view=diff
==============================================================================
---
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/RegExLoader.java
(original)
+++
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/RegExLoader.java
Fri Dec 4 17:35:13 2009
@@ -31,6 +31,7 @@
import org.apache.pig.data.TupleFactory;
import org.apache.pig.impl.io.BufferedPositionedInputStream;
import org.apache.pig.impl.logicalLayer.schema.Schema;
+import org.apache.pig.impl.logicalLayer.FrontendException;
/**
* RegExLoader is an abstract class used to parse logs based on a regular
expression.
@@ -110,6 +111,10 @@
public Schema determineSchema(String fileName, ExecType execType,
DataStorage storage) throws IOException {
return null;
}
- public void fieldsToRead(Schema schema) {
+
+ @Override
+ public LoadFunc.RequiredFieldResponse
fieldsToRead(LoadFunc.RequiredFieldList requiredFieldList) throws
FrontendException {
+ return new LoadFunc.RequiredFieldResponse(false);
}
+
}
Modified:
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/SequenceFileLoader.java
URL:
http://svn.apache.org/viewvc/hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/SequenceFileLoader.java?rev=887285&r1=887284&r2=887285&view=diff
==============================================================================
---
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/SequenceFileLoader.java
(original)
+++
hadoop/pig/branches/branch-0.6/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/SequenceFileLoader.java
Fri Dec 4 17:35:13 2009
@@ -38,6 +38,7 @@
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.serializer.SerializationFactory;
import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.pig.impl.logicalLayer.FrontendException;
import org.apache.pig.ExecType;
import org.apache.pig.LoadFunc;
@@ -168,9 +169,8 @@
}
@Override
- public void fieldsToRead(Schema schema) {
- // not implemented
-
+ public LoadFunc.RequiredFieldResponse
fieldsToRead(LoadFunc.RequiredFieldList requiredFieldList) throws
FrontendException {
+ return new LoadFunc.RequiredFieldResponse(false);
}
@Override
