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 <jbel...@apache.org> Authored: Fri Sep 21 12:20:45 2012 -0500 Committer: Jonathan Ellis <jbel...@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
