public class SimpleKafkaETLMapper extends java.lang.Object implements org.apache.hadoop.mapred.Mapper<KafkaETLKey,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
Modifier and Type | Field and Description |
---|---|
protected long |
_count |
Constructor and Description |
---|
SimpleKafkaETLMapper() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(org.apache.hadoop.mapred.JobConf arg0) |
protected org.apache.hadoop.io.Text |
getData(kafka.message.Message message) |
void |
map(KafkaETLKey key,
org.apache.hadoop.io.BytesWritable val,
org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> collector,
org.apache.hadoop.mapred.Reporter reporter) |
protected org.apache.hadoop.io.Text getData(kafka.message.Message message) throws java.io.IOException
java.io.IOException
public void map(KafkaETLKey key, org.apache.hadoop.io.BytesWritable val, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> collector, org.apache.hadoop.mapred.Reporter reporter) throws java.io.IOException
map
in interface org.apache.hadoop.mapred.Mapper<KafkaETLKey,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
java.io.IOException
public void configure(org.apache.hadoop.mapred.JobConf arg0)
configure
in interface org.apache.hadoop.mapred.JobConfigurable
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException