Author: brandonwilliams Date: Mon Dec 6 23:34:05 2010 New Revision: 1042857
URL: http://svn.apache.org/viewvc?rev=1042857&view=rev Log: word_count uses better ks/cf names now that we're not piggybacking off storage definitions in the config. Patch by brandonwilliams Modified: cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java cassandra/trunk/contrib/word_count/src/WordCount.java Modified: cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java?rev=1042857&r1=1042856&r2=1042857&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java (original) +++ cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java Mon Dec 6 23:34:05 2010 @@ -54,11 +54,11 @@ public class WordCount extends Configure { private static final Logger logger = LoggerFactory.getLogger(WordCount.class); - static final String KEYSPACE = "Keyspace1"; - static final String COLUMN_FAMILY = "Standard1"; + static final String KEYSPACE = "wordcount"; + static final String COLUMN_FAMILY = "input_words"; static final String OUTPUT_REDUCER_VAR = "output_reducer"; - static final String OUTPUT_COLUMN_FAMILY = "Standard2"; + static final String OUTPUT_COLUMN_FAMILY = "output_words"; private static final String OUTPUT_PATH_PREFIX = "/tmp/word_count"; private static final String CONF_COLUMN_NAME = "columnname"; Modified: cassandra/trunk/contrib/word_count/src/WordCount.java URL: http://svn.apache.org/viewvc/cassandra/trunk/contrib/word_count/src/WordCount.java?rev=1042857&r1=1042856&r2=1042857&view=diff ============================================================================== --- cassandra/trunk/contrib/word_count/src/WordCount.java (original) +++ cassandra/trunk/contrib/word_count/src/WordCount.java Mon Dec 6 23:34:05 2010 @@ -54,11 +54,11 @@ public class WordCount extends Configure { private static final Logger logger = LoggerFactory.getLogger(WordCount.class); - static final String KEYSPACE = "Keyspace1"; - static final String COLUMN_FAMILY = "Standard1"; + static final String KEYSPACE = "wordcount"; + static final String COLUMN_FAMILY = "input_words"; static final String OUTPUT_REDUCER_VAR = "output_reducer"; - static final String OUTPUT_COLUMN_FAMILY = "Standard2"; + static final String OUTPUT_COLUMN_FAMILY = "output_words"; private static final String OUTPUT_PATH_PREFIX = "/tmp/word_count"; private static final String CONF_COLUMN_NAME = "columnname";
