elasticsearch-hadoop-cascading

org.elasticsearch.hadoop.mr
Class EsOutputFormat.EsRecordWriter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordWriter
      extended by org.elasticsearch.hadoop.mr.EsOutputFormat.EsRecordWriter
All Implemented Interfaces:
RecordWriter
Enclosing class:
EsOutputFormat

protected static class EsOutputFormat.EsRecordWriter
extends RecordWriter
implements RecordWriter


Field Summary
protected  Configuration cfg
           
protected  boolean initialized
           
protected  org.elasticsearch.hadoop.rest.RestRepository repository
           
 
Constructor Summary
EsOutputFormat.EsRecordWriter(Configuration cfg, Progressable progressable)
           
 
Method Summary
 void close(Reporter reporter)
           
 void close(TaskAttemptContext context)
           
protected  void doClose(Progressable progressable)
           
protected  void init()
           
 void write(Object key, 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

EsOutputFormat.EsRecordWriter

public EsOutputFormat.EsRecordWriter(Configuration cfg,
                                     Progressable progressable)
Method Detail

write

public void write(Object key,
                  Object value)
           throws IOException
Specified by:
write in interface RecordWriter
Specified by:
write in class RecordWriter
Throws:
IOException

init

protected void init()
             throws IOException
Throws:
IOException

close

public void close(TaskAttemptContext context)
           throws IOException
Specified by:
close in class RecordWriter
Throws:
IOException

close

public void close(Reporter reporter)
           throws IOException
Specified by:
close in interface RecordWriter
Throws:
IOException

doClose

protected void doClose(Progressable progressable)

elasticsearch-hadoop-cascading