public class EsOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat
implements org.apache.hadoop.mapred.OutputFormat
OutputFormat (old and new API) for adding data to an index inside ElasticSearch.| Modifier and Type | Class and Description |
|---|---|
static class |
EsOutputFormat.EsOldAPIOutputCommitter |
static class |
EsOutputFormat.EsOutputCommitter |
protected static class |
EsOutputFormat.EsRecordWriter |
| Constructor and Description |
|---|
EsOutputFormat() |
| Modifier and Type | Method and Description |
|---|---|
void |
checkOutputSpecs(FileSystem ignored,
org.apache.hadoop.mapred.JobConf cfg) |
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) |
org.apache.hadoop.mapreduce.OutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapred.RecordWriter |
getRecordWriter(FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
java.lang.String name,
org.apache.hadoop.util.Progressable progress) |
org.apache.hadoop.mapreduce.RecordWriter |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
public org.apache.hadoop.mapreduce.RecordWriter getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormatpublic void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
throws java.io.IOException
checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormatjava.io.IOExceptionpublic org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormatpublic org.apache.hadoop.mapred.RecordWriter getRecordWriter(FileSystem ignored, org.apache.hadoop.mapred.JobConf job, java.lang.String name, org.apache.hadoop.util.Progressable progress)
getRecordWriter in interface org.apache.hadoop.mapred.OutputFormatpublic void checkOutputSpecs(FileSystem ignored, org.apache.hadoop.mapred.JobConf cfg) throws java.io.IOException
checkOutputSpecs in interface org.apache.hadoop.mapred.OutputFormatjava.io.IOException