protected static class EsOutputFormat.EsRecordWriter extends RecordWriter implements RecordWriter
| Modifier and Type | Field and Description |
|---|---|
protected Configuration |
cfg |
protected boolean |
initialized |
protected org.elasticsearch.hadoop.rest.RestRepository |
repository |
| Constructor and Description |
|---|
EsRecordWriter(Configuration cfg,
Progressable progressable) |
| Modifier and Type | Method and Description |
|---|---|
void |
close(Reporter reporter) |
void |
close(TaskAttemptContext context) |
protected void |
doClose(Progressable progressable) |
protected void |
init() |
void |
write(java.lang.Object key,
java.lang.Object value) |
protected final Configuration cfg
protected boolean initialized
protected org.elasticsearch.hadoop.rest.RestRepository repository
public EsRecordWriter(Configuration cfg, Progressable progressable)
public void write(java.lang.Object key,
java.lang.Object value)
throws java.io.IOException
write in interface RecordWriterwrite in class RecordWriterjava.io.IOExceptionprotected void init()
throws java.io.IOException
java.io.IOExceptionpublic void close(TaskAttemptContext context) throws java.io.IOException
close in class RecordWriterjava.io.IOExceptionpublic void close(Reporter reporter) throws java.io.IOException
close in interface RecordWriterjava.io.IOExceptionprotected void doClose(Progressable progressable)