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 |
|---|
EsOutputFormat.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(Object key,
Object value) |
protected final Configuration cfg
protected boolean initialized
protected org.elasticsearch.hadoop.rest.RestRepository repository
public EsOutputFormat.EsRecordWriter(Configuration cfg, Progressable progressable)
public void write(Object key, Object value) throws IOException
write in interface RecordWriterwrite in class RecordWriterIOExceptionprotected void init()
throws IOException
IOExceptionpublic void close(TaskAttemptContext context) throws IOException
close in class RecordWriterIOExceptionpublic void close(Reporter reporter) throws IOException
close in interface RecordWriterIOExceptionprotected void doClose(Progressable progressable)