T
- the type of the result computed by the jobpublic interface Input<T>
Modifier and Type | Method and 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.
|
boolean |
shouldBeComputedDirectly()
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.
|
boolean shouldBeComputedDirectly()
true
if this entity should be computed directly,
false
otherwiseOutput<T> computeDirectly()
java.util.List<MapReduceTask<T>> split()