Interface Grouping<S,​K,​V>

    • Method Detail

      • getKeyTraversal

        Traversal.Admin<S,​K> getKeyTraversal()
        Determines if the provided traversal is equal to the key traversal that the Grouping has.
      • getValueTraversal

        Traversal.Admin<S,​V> getValueTraversal()
        Determines if the provided traversal is equal to the value traversal that the Grouping has.
      • hasBarrierInValueTraversal

        default boolean hasBarrierInValueTraversal()
        Checks if there is a non-local Barrier in the value traversal.
      • determineBarrierStep

        default Barrier determineBarrierStep​(Traversal.Admin<S,​V> traversal)
        Determines the first non-local Barrier step in the provided traversal. This method is used by GroupStep and GroupSideEffectStep to ultimately determine the reducing bi-operator.
        Parameters:
        traversal - The traversal to inspect.
        Returns:
        The first non-local barrier step or null if no such step was found.