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(Object key,
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(Object key, Object value) throws IOException
write
in interface RecordWriter
write
in class RecordWriter
IOException
protected void init() throws IOException
IOException
public void close(TaskAttemptContext context) throws IOException
close
in class RecordWriter
IOException
public void close(Reporter reporter) throws IOException
close
in interface RecordWriter
IOException
protected void doClose(Progressable progressable)