Interface Input<T>
-
- Type Parameters:
T- the type of the result computed by the job
public interface Input<T>Interface for Map/Reduce input entities. An input entity can be split into sub-entities that will eventually be subject to the map phase of the Map/Reduce job.- Author:
- patrick.peschlow
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Output<T>computeDirectly()Performs the computation for this entity directly (i.e., the map phase of the job) and returns the output object carrying the result for this entity.booleanshouldBeComputedDirectly()Determines whether this entity should be computed directly or split further into smaller entities.java.util.List<MapReduceTask<T>>split()Splits this entity into a number of MapReduceTasks which can then be submitted to a ForkJoinPool.
-
-
-
Method Detail
-
shouldBeComputedDirectly
boolean shouldBeComputedDirectly()
Determines whether this entity should be computed directly or split further into smaller entities.- Returns:
trueif this entity should be computed directly,falseotherwise
-
computeDirectly
Output<T> computeDirectly()
Performs the computation for this entity directly (i.e., the map phase of the job) and returns the output object carrying the result for this entity.- Returns:
- the output object returned by the computation
-
split
java.util.List<MapReduceTask<T>> split()
Splits this entity into a number of MapReduceTasks which can then be submitted to a ForkJoinPool.- Returns:
- a list of MapReduceTasks representing subtasks of this task
-
-