This project has retired. For details please refer to its
Attic page .
UnionReadableData (Apache Crunch 0.11.0 API)
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.