natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "fix references to defunct CqlPagingInputFormat" 

This reverts commit e550ea6021.
This commit is contained in:
Aleksey Yeschenko 2015-01-07 02:25:09 +03:00
parent e20810c7bd
commit e27cdf935c
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/hadoop_cql3_word_count/src/WordCount.java
View File

@ -26,6 +26,7 @@ import org.apache.cassandra.hadoop.cql3.CqlOutputFormat;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.apache.cassandra.hadoop.cql3.CqlPagingInputFormat;
import org.apache.cassandra.hadoop.cql3.CqlInputFormat; import org.apache.cassandra.hadoop.cql3.CqlInputFormat;
import org.apache.cassandra.hadoop.ConfigHelper; import org.apache.cassandra.hadoop.ConfigHelper;
import org.apache.cassandra.utils.ByteBufferUtil; import org.apache.cassandra.utils.ByteBufferUtil;
@ -246,7 +247,7 @@ public class WordCount extends Configured implements Tool
else else
{ {
job.setMapperClass(TokenizerMapper.class); job.setMapperClass(TokenizerMapper.class);
job.setInputFormatClass(CqlInputFormat.class); job.setInputFormatClass(CqlPagingInputFormat.class);
ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160"); ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160");
} }

3
examples/hadoop_cql3_word_count/src/WordCountCounters.java
View File

@ -25,6 +25,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.apache.cassandra.hadoop.cql3.CqlConfigHelper; import org.apache.cassandra.hadoop.cql3.CqlConfigHelper;
import org.apache.cassandra.hadoop.cql3.CqlPagingInputFormat;
import org.apache.cassandra.hadoop.cql3.CqlInputFormat; import org.apache.cassandra.hadoop.cql3.CqlInputFormat;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.conf.Configured; import org.apache.hadoop.conf.Configured;
@ -155,7 +156,7 @@ public class WordCountCounters extends Configured implements Tool
else else
{ {
job.setMapperClass(SumMapper.class); job.setMapperClass(SumMapper.class);
job.setInputFormatClass(CqlInputFormat.class); job.setInputFormatClass(CqlPagingInputFormat.class);
ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160"); ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160");
} }

2
src/java/org/apache/cassandra/hadoop/pig/CqlStorage.java
View File

@ -74,7 +74,7 @@ public class CqlStorage extends AbstractCassandraStorage
{ {
super(); super();
this.pageSize = pageSize; this.pageSize = pageSize;
DEFAULT_INPUT_FORMAT = "org.apache.cassandra.hadoop.cql3.CqlInputFormat"; DEFAULT_INPUT_FORMAT = "org.apache.cassandra.hadoop.cql3.CqlPagingInputFormat";
DEFAULT_OUTPUT_FORMAT = "org.apache.cassandra.hadoop.cql3.CqlOutputFormat"; DEFAULT_OUTPUT_FORMAT = "org.apache.cassandra.hadoop.cql3.CqlOutputFormat";
} }