Interface RCollator<K,V,R>

  • Type Parameters:
    K - key type
    V - value type
    R - result type
    All Superinterfaces:
    Serializable

    public interface RCollator<K,V,R>
    extends Serializable
    Collates result from RReducer tasks and produces a single result object. Executes only once.
    Author:
    Nikita Koksharov
    • Method Detail

      • collate

        R collate(Map<K,V> resultMap)
        Collates result map from reduce phase of MapReduce process.
        Parameters:
        resultMap - contains reduced entires
        Returns:
        single result object