public class KafkaETLRecordReader extends org.apache.hadoop.mapred.SequenceFileRecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
_attemptId |
protected int |
_contextIndex |
protected java.util.List<KafkaETLContext> |
_contextList |
protected org.apache.hadoop.mapred.JobConf |
_job |
protected org.apache.hadoop.mapred.lib.MultipleOutputs |
_mos |
protected Props |
_props |
protected long |
_readBytes |
protected long |
_readCounts |
protected org.apache.hadoop.mapred.Reporter |
_reporter |
protected long |
_totalBytes |
Constructor and Description |
---|
KafkaETLRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
KafkaETLKey |
createKey() |
org.apache.hadoop.io.BytesWritable |
createValue() |
protected KafkaETLContext |
getContext() |
float |
getProgress() |
boolean |
next(KafkaETLKey key,
org.apache.hadoop.io.BytesWritable value) |
protected Props _props
protected org.apache.hadoop.mapred.JobConf _job
protected org.apache.hadoop.mapred.Reporter _reporter
protected org.apache.hadoop.mapred.lib.MultipleOutputs _mos
protected java.util.List<KafkaETLContext> _contextList
protected int _contextIndex
protected long _totalBytes
protected long _readBytes
protected long _readCounts
protected java.lang.String _attemptId
public KafkaETLRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
close
in interface org.apache.hadoop.mapred.RecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
close
in class org.apache.hadoop.mapred.SequenceFileRecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public KafkaETLKey createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
createKey
in class org.apache.hadoop.mapred.SequenceFileRecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
public org.apache.hadoop.io.BytesWritable createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
createValue
in class org.apache.hadoop.mapred.SequenceFileRecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
public float getProgress() throws java.io.IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
getProgress
in class org.apache.hadoop.mapred.SequenceFileRecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public boolean next(KafkaETLKey key, org.apache.hadoop.io.BytesWritable value) throws java.io.IOException
next
in interface org.apache.hadoop.mapred.RecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
next
in class org.apache.hadoop.mapred.SequenceFileRecordReader<KafkaETLKey,org.apache.hadoop.io.BytesWritable>
java.io.IOException
protected KafkaETLContext getContext() throws java.io.IOException
java.io.IOException