com.github.panhongan.util.hadoop

类 CombineSequenceFileRecordReader<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<K,V>

com.github.panhongan.util.hadoop.CombineSequenceFileRecordReader<K,V>

所有已实现的接口:

Closeable, AutoCloseable

public class CombineSequenceFileRecordReader<K,V>
extends org.apache.hadoop.mapreduce.RecordReader<K,V>

构造器概要

构造器

构造器和说明
CombineSequenceFileRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context, Integer index)

方法概要

方法

限定符和类型	方法和说明
void	close()
K	getCurrentKey()
V	getCurrentValue()
float	getProgress()
void	initialize(org.apache.hadoop.mapreduce.InputSplit curSplit, org.apache.hadoop.mapreduce.TaskAttemptContext curContext)
boolean	nextKeyValue()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

CombineSequenceFileRecordReader

public CombineSequenceFileRecordReader(org.apache.hadoop.mapreduce.lib.input.CombineFileSplit split,
                               org.apache.hadoop.mapreduce.TaskAttemptContext context,
                               Integer index)
                                throws IOException,
                                       InterruptedException

抛出:

IOException

InterruptedException

方法详细资料

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit curSplit,
              org.apache.hadoop.mapreduce.TaskAttemptContext curContext)
                throws IOException,
                       InterruptedException

指定者:

initialize 在类中 org.apache.hadoop.mapreduce.RecordReader<K,V>

抛出:

IOException

InterruptedException

getProgress

public float getProgress()
                  throws IOException,
                         InterruptedException

指定者:

getProgress 在类中 org.apache.hadoop.mapreduce.RecordReader<K,V>

抛出:

IOException

InterruptedException

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

指定者:

close 在类中 org.apache.hadoop.mapreduce.RecordReader<K,V>

抛出:

IOException

getCurrentKey

public K getCurrentKey()
                throws IOException,
                       InterruptedException

指定者:

getCurrentKey 在类中 org.apache.hadoop.mapreduce.RecordReader<K,V>

抛出:

IOException

InterruptedException

getCurrentValue

public V getCurrentValue()
                  throws IOException,
                         InterruptedException

指定者:

getCurrentValue 在类中 org.apache.hadoop.mapreduce.RecordReader<K,V>

抛出:

IOException

InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws IOException,
                            InterruptedException

指定者:

nextKeyValue 在类中 org.apache.hadoop.mapreduce.RecordReader<K,V>

抛出:

IOException

InterruptedException