delete isSplitable function

namespace-io · Dec 17, 2018 · 0718e93 · 0718e93
1 parent ecff509
commit 0718e93
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/src/main/java/CWInputFormat.java b/src/main/java/CWInputFormat.java
@@ -1,7 +1,5 @@
-import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.IntWritable;
 import org.apache.hadoop.mapreduce.InputSplit;
-import org.apache.hadoop.mapreduce.JobContext;
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
@@ -11,11 +9,6 @@
 // 计算条件概率时,将<classname, word>作为Mapper的输入
 public class CWInputFormat extends FileInputFormat<PairWritable, IntWritable> {
 
-    @Override
-    protected boolean isSplitable(JobContext context, Path filename) {
-        return false;
-    }
-
     @Override
     public RecordReader<PairWritable, IntWritable> createRecordReader(InputSplit inputSplit, TaskAttemptContext taskAttemptContext) throws IOException, InterruptedException {