cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [2/2] git commit: update error messages for setX to setInputX change patch by Philip Crotwell; reviewed by jbellis for CASSANDRA-4688
Date Sat, 22 Sep 2012 20:19:06 GMT
update error messages for setX to setInputX change
patch by Philip Crotwell; reviewed by jbellis for CASSANDRA-4688


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/fe5fa0e8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/fe5fa0e8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/fe5fa0e8

Branch: refs/heads/trunk
Commit: fe5fa0e81b4a90516a1b6a22d7952a72a9a541bb
Parents: d634f05
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Fri Sep 21 12:20:45 2012 -0500
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Sat Sep 22 15:16:11 2012 -0500

----------------------------------------------------------------------
 .../cassandra/hadoop/ColumnFamilyInputFormat.java  |   12 ++++++------
 1 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/fe5fa0e8/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java b/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
index 047130a..53da91a 100644
--- a/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
+++ b/src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java
@@ -59,8 +59,8 @@ import org.slf4j.LoggerFactory;
  * At minimum, you need to set the CF and predicate (description of columns to extract from
each row)
  * in your Hadoop job Configuration.  The ConfigHelper class is provided to make this
  * simple:
- *   ConfigHelper.setColumnFamily
- *   ConfigHelper.setSlicePredicate
+ *   ConfigHelper.setInputColumnFamily
+ *   ConfigHelper.setInputSlicePredicate
  *
  * You can also configure the number of rows per InputSplit with
  *   ConfigHelper.setInputSplitSize
@@ -91,16 +91,16 @@ public class ColumnFamilyInputFormat extends InputFormat<ByteBuffer,
SortedMap<B
     {
         if (ConfigHelper.getInputKeyspace(conf) == null || ConfigHelper.getInputColumnFamily(conf)
== null)
         {
-            throw new UnsupportedOperationException("you must set the keyspace and columnfamily
with setColumnFamily()");
+            throw new UnsupportedOperationException("you must set the keyspace and columnfamily
with setInputColumnFamily()");
         }
         if (ConfigHelper.getInputSlicePredicate(conf) == null)
         {
-            throw new UnsupportedOperationException("you must set the predicate with setPredicate");
+            throw new UnsupportedOperationException("you must set the predicate with setInputSlicePredicate");
         }
         if (ConfigHelper.getInputInitialAddress(conf) == null)
-            throw new UnsupportedOperationException("You must set the initial output address
to a Cassandra node");
+            throw new UnsupportedOperationException("You must set the initial output address
to a Cassandra node with setInputInitialAddress");
         if (ConfigHelper.getInputPartitioner(conf) == null)
-            throw new UnsupportedOperationException("You must set the Cassandra partitioner
class");
+            throw new UnsupportedOperationException("You must set the Cassandra partitioner
class with setInputPartitioner");
     }
 
     public List<InputSplit> getSplits(JobContext context) throws IOException


Mime
View raw message