org.apache.crunch.util
Class UnionReadableData<T>
java.lang.Object
org.apache.crunch.util.UnionReadableData<T>
- All Implemented Interfaces:
- Serializable, ReadableData<T>
public class UnionReadableData<T>
- extends Object
- implements ReadableData<T>
- See Also:
- Serialized Form
Method Summary |
void |
configure(org.apache.hadoop.conf.Configuration conf)
Allows this instance to specify any additional configuration settings that may
be needed by the job that it is launched in. |
Set<SourceTarget<?>> |
getSourceTargets()
|
Iterable<T> |
read(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
Read the data referenced by this instance within the given context. |
UnionReadableData
public UnionReadableData(List<ReadableData<T>> data)
getSourceTargets
public Set<SourceTarget<?>> getSourceTargets()
- Specified by:
getSourceTargets
in interface ReadableData<T>
- Returns:
- Any
SourceTarget
instances that must exist before the data in
this instance can be read. Used by the planner in sequencing job processing.
configure
public void configure(org.apache.hadoop.conf.Configuration conf)
- Description copied from interface:
ReadableData
- Allows this instance to specify any additional configuration settings that may
be needed by the job that it is launched in.
- Specified by:
configure
in interface ReadableData<T>
- Parameters:
conf
- The Configuration
object for the job
read
public Iterable<T> read(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
throws IOException
- Description copied from interface:
ReadableData
- Read the data referenced by this instance within the given context.
- Specified by:
read
in interface ReadableData<T>
- Parameters:
context
- The context of the task that is reading the data
- Returns:
- An iterable reference to the data in this instance
- Throws:
IOException
- If the data cannot be read
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.