E
- The type of entities in the Dataset
.public class DatasetKeyOutputFormat<E> extends OutputFormat<E,Void>
OutputFormat
for writing to a Dataset
.
Since a Dataset
only contains entities (not key/value pairs), this output
format ignores the value.Modifier and Type | Class and Description |
---|---|
static class |
DatasetKeyOutputFormat.ConfigBuilder |
Modifier and Type | Field and Description |
---|---|
static String |
KITE_OUTPUT_URI |
static String |
KITE_PARTITION_DIR |
static String |
KITE_TYPE |
Constructor and Description |
---|
DatasetKeyOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(JobContext jobContext) |
static DatasetKeyOutputFormat.ConfigBuilder |
configure(Configuration conf)
Returns a helper to add output options to the given
Configuration . |
static DatasetKeyOutputFormat.ConfigBuilder |
configure(Job job)
Configures the
Job to use the DatasetKeyOutputFormat and
returns a helper to add further configuration. |
OutputCommitter |
getOutputCommitter(TaskAttemptContext taskAttemptContext) |
RecordWriter<E,Void> |
getRecordWriter(TaskAttemptContext taskAttemptContext) |
public static final String KITE_OUTPUT_URI
public static final String KITE_PARTITION_DIR
public static final String KITE_TYPE
public static DatasetKeyOutputFormat.ConfigBuilder configure(Job job)
Job
to use the DatasetKeyOutputFormat
and
returns a helper to add further configuration.job
- the Job
to configurepublic static DatasetKeyOutputFormat.ConfigBuilder configure(Configuration conf)
Configuration
.conf
- a Configuration
public RecordWriter<E,Void> getRecordWriter(TaskAttemptContext taskAttemptContext)
getRecordWriter
in class OutputFormat<E,Void>
public void checkOutputSpecs(JobContext jobContext)
checkOutputSpecs
in class OutputFormat<E,Void>
public OutputCommitter getOutputCommitter(TaskAttemptContext taskAttemptContext)
getOutputCommitter
in class OutputFormat<E,Void>
Copyright © 2013–2015. All rights reserved.