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.
      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.
    • Method Detail

      • shouldBeComputedDirectly

        boolean shouldBeComputedDirectly()
        Determines whether this entity should be computed directly or split further into smaller entities.
        Returns:
        true if this entity should be computed directly, false otherwise
      • 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