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()
