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