public class EsOutputFormat extends OutputFormat implements 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,
JobConf cfg) |
void |
checkOutputSpecs(JobContext context) |
OutputCommitter |
getOutputCommitter(TaskAttemptContext context) |
RecordWriter |
getRecordWriter(FileSystem ignored,
JobConf job,
java.lang.String name,
Progressable progress) |
RecordWriter |
getRecordWriter(TaskAttemptContext context) |
public RecordWriter getRecordWriter(TaskAttemptContext context)
getRecordWriter in class OutputFormatpublic void checkOutputSpecs(JobContext context) throws java.io.IOException
checkOutputSpecs in class OutputFormatjava.io.IOExceptionpublic OutputCommitter getOutputCommitter(TaskAttemptContext context)
getOutputCommitter in class OutputFormatpublic RecordWriter getRecordWriter(FileSystem ignored, JobConf job, java.lang.String name, Progressable progress)
getRecordWriter in interface OutputFormatpublic void checkOutputSpecs(FileSystem ignored, JobConf cfg) throws java.io.IOException
checkOutputSpecs in interface OutputFormatjava.io.IOException