svn commit: r1094195 - /cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java

[br...@apache.org]

Author: brandonwilliams
Date: Sun Apr 17 21:11:26 2011
New Revision: 1094195

URL: http://svn.apache.org/viewvc?rev=1094195&view=rev
Log:
Remove LoadPushDown methods from pig storage.
Patch by Jeremy Hanna, reviewed by brandonwilliams for CASSANDRA-2484

Modified:
    cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java

Modified: cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java?rev=1094195&r1=1094194&r2=1094195&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java (original)
+++ cassandra/branches/cassandra-0.7/contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java Sun Apr 17 21:11:26 2011
@@ -56,11 +56,11 @@ import org.apache.thrift.transport.TTran
 import org.apache.thrift.transport.TTransportException;
 
 /**
- * A LoadFunc wrapping ColumnFamilyInputFormat.
+ * A LoadStoreFunc for retrieving data from and storing data to Cassandra
  *
  * A row from a standard CF will be returned as nested tuples: (key, ((name1, val1), (name2, val2))).
  */
-public class CassandraStorage extends LoadFunc implements StoreFuncInterface, LoadPushDown
+public class CassandraStorage extends LoadFunc implements StoreFuncInterface
 {
     // system environment variables that can be set to configure connection info:
     // alternatively, Hadoop JobConf variables can be set using keys from ConfigHelper
@@ -428,18 +428,6 @@ public class CassandraStorage extends Lo
     {
     }
 
-    /* LoadPushDown methods */
-
-    public List<OperatorSet> getFeatures() {
-        return Arrays.asList(LoadPushDown.OperatorSet.PROJECTION);
-    }
-
-    public RequiredFieldResponse pushProjection(RequiredFieldList requiredFieldList) throws FrontendException
-    {
-        return new RequiredFieldResponse(true);
-    }
-
-
     /* Methods to get the column family schema from Cassandra */
 
     private void initSchema()