public class KafkaRecordWriter<K,V>
extends org.apache.hadoop.mapreduce.RecordWriter<K,V>
Modifier and Type | Field and Description |
---|---|
protected java.util.List<kafka.producer.KeyedMessage<java.lang.Object,byte[]>> |
msgList |
protected kafka.javaapi.producer.Producer<java.lang.Object,byte[]> |
producer |
protected int |
queueBytes |
protected java.lang.String |
topic |
protected int |
totalBytes |
Constructor and Description |
---|
KafkaRecordWriter(kafka.javaapi.producer.Producer<java.lang.Object,byte[]> producer,
java.lang.String topic,
int queueBytes) |
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
protected void |
sendMsgList() |
void |
write(K key,
V value) |
protected kafka.javaapi.producer.Producer<java.lang.Object,byte[]> producer
protected java.lang.String topic
protected java.util.List<kafka.producer.KeyedMessage<java.lang.Object,byte[]>> msgList
protected int totalBytes
protected int queueBytes
public KafkaRecordWriter(kafka.javaapi.producer.Producer<java.lang.Object,byte[]> producer, java.lang.String topic, int queueBytes)