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 |
|---|
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 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.RecordWriterwrite in class org.apache.hadoop.mapreduce.RecordWriterjava.io.IOExceptionprotected void init()
throws java.io.IOException
java.io.IOExceptionpublic void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws java.io.IOException
close in class org.apache.hadoop.mapreduce.RecordWriterjava.io.IOExceptionpublic void close(org.apache.hadoop.mapred.Reporter reporter)
throws java.io.IOException
close in interface org.apache.hadoop.mapred.RecordWriterjava.io.IOExceptionprotected void doClose(org.apache.hadoop.util.Progressable progressable)