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