|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.mapreduce.InputFormat<E,Void>
org.kitesdk.data.mapreduce.DatasetKeyInputFormat<E>
E
- The type of entities in the Dataset
.@Beta public class DatasetKeyInputFormat<E>
A MapReduce InputFormat
for reading from a Dataset
.
Since a Dataset
only contains entities (not key/value pairs), this output
format ignores the value.
Nested Class Summary | |
---|---|
static class |
DatasetKeyInputFormat.ConfigBuilder
|
Field Summary | |
---|---|
static String |
KITE_CONSTRAINTS
|
static String |
KITE_DATASET_NAME
Deprecated. |
static String |
KITE_INPUT_URI
|
static String |
KITE_PARTITION_DIR
|
static String |
KITE_REPOSITORY_URI
Deprecated. |
static String |
KITE_TYPE
|
Constructor Summary | |
---|---|
DatasetKeyInputFormat()
|
Method Summary | ||
---|---|---|
static DatasetKeyInputFormat.ConfigBuilder |
configure(Configuration conf)
Returns a helper to add input options to the given Configuration . |
|
static DatasetKeyInputFormat.ConfigBuilder |
configure(Job job)
Configures the Job to use the DatasetKeyInputFormat and
returns a helper to add further configuration. |
|
RecordReader<E,Void> |
createRecordReader(InputSplit inputSplit,
TaskAttemptContext taskAttemptContext)
|
|
Configuration |
getConf()
|
|
List<InputSplit> |
getSplits(JobContext jobContext)
|
|
void |
setConf(Configuration configuration)
|
|
static void |
setDatasetName(Job job,
String name)
Deprecated. will be removed in 0.16.0; use configure(Job) instead |
|
static void |
setRepositoryUri(Job job,
URI uri)
Deprecated. will be removed in 0.16.0; use configure(Job) instead |
|
static
|
setView(Configuration conf,
View<E> view)
Deprecated. will be removed in 0.16.0; use configure(Configuration) |
|
static
|
setView(Job job,
View<E> view)
Deprecated. will be removed in 0.16.0; use configure(Job) instead |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String KITE_INPUT_URI
@Deprecated public static final String KITE_REPOSITORY_URI
@Deprecated public static final String KITE_DATASET_NAME
public static final String KITE_PARTITION_DIR
public static final String KITE_CONSTRAINTS
public static final String KITE_TYPE
Constructor Detail |
---|
public DatasetKeyInputFormat()
Method Detail |
---|
public static DatasetKeyInputFormat.ConfigBuilder configure(Job job)
Job
to use the DatasetKeyInputFormat
and
returns a helper to add further configuration.
job
- the Job
to configurepublic static DatasetKeyInputFormat.ConfigBuilder configure(Configuration conf)
Configuration
.
conf
- a Configuration
@Deprecated public static void setRepositoryUri(Job job, URI uri)
configure(Job)
instead
@Deprecated public static void setDatasetName(Job job, String name)
configure(Job)
instead
@Deprecated public static <E> void setView(Job job, View<E> view)
configure(Job)
instead
@Deprecated public static <E> void setView(Configuration conf, View<E> view)
configure(Configuration)
public Configuration getConf()
getConf
in interface Configurable
public void setConf(Configuration configuration)
setConf
in interface Configurable
public List<InputSplit> getSplits(JobContext jobContext) throws IOException, InterruptedException
getSplits
in class InputFormat<E,Void>
IOException
InterruptedException
public RecordReader<E,Void> createRecordReader(InputSplit inputSplit, TaskAttemptContext taskAttemptContext) throws IOException, InterruptedException
createRecordReader
in class InputFormat<E,Void>
IOException
InterruptedException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |