org.elasticsearch.hadoop.mr
Class EsOutputFormat.EsRecordWriter
java.lang.Object
org.apache.hadoop.mapreduce.RecordWriter
org.elasticsearch.hadoop.mr.EsOutputFormat.EsRecordWriter
- All Implemented Interfaces:
- RecordWriter
- Enclosing class:
- EsOutputFormat
protected static class EsOutputFormat.EsRecordWriter
- extends RecordWriter
- implements RecordWriter
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
cfg
protected final Configuration cfg
initialized
protected boolean initialized
repository
protected org.elasticsearch.hadoop.rest.RestRepository repository
EsOutputFormat.EsRecordWriter
public EsOutputFormat.EsRecordWriter(Configuration cfg,
Progressable progressable)
write
public void write(Object key,
Object value)
throws IOException
- Specified by:
write
in interface RecordWriter
- Specified by:
write
in class RecordWriter
- Throws:
IOException
init
protected void init()
throws IOException
- Throws:
IOException
close
public void close(TaskAttemptContext context)
throws IOException
- Specified by:
close
in class RecordWriter
- Throws:
IOException
close
public void close(Reporter reporter)
throws IOException
- Specified by:
close
in interface RecordWriter
- Throws:
IOException
doClose
protected void doClose(Progressable progressable)