org.elasticsearch.hadoop.mr

Class EsOutputFormat.EsRecordWriter

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter

org.elasticsearch.hadoop.mr.EsOutputFormat.EsRecordWriter

All Implemented Interfaces:

RecordWriter

Enclosing class:

EsOutputFormat

protected static class EsOutputFormat.EsRecordWriter
extends RecordWriter
implements RecordWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	cfg
protected boolean	initialized
protected org.elasticsearch.hadoop.rest.RestRepository	repository

Constructor Summary

Constructors

Constructor and Description
EsRecordWriter(Configuration cfg, Progressable progressable)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cfg

protected final Configuration cfg

initialized

protected boolean initialized

repository

protected org.elasticsearch.hadoop.rest.RestRepository repository

Constructor Detail

EsRecordWriter

public EsRecordWriter(Configuration cfg,
                      Progressable progressable)

Method Detail

write

public void write(java.lang.Object key,
                  java.lang.Object value)
           throws java.io.IOException

Specified by:

write in interface RecordWriter

Specified by:

write in class RecordWriter

Throws:

java.io.IOException

init

protected void init()
             throws java.io.IOException

Throws:

java.io.IOException

close

public void close(TaskAttemptContext context)
           throws java.io.IOException

Specified by:

close in class RecordWriter

Throws:

java.io.IOException

close

public void close(Reporter reporter)
           throws java.io.IOException

Specified by:

close in interface RecordWriter

Throws:

java.io.IOException

doClose

protected void doClose(Progressable progressable)