Class ProfilingAware.ProfiledBarrier

    • Constructor Detail

    • Method Detail

      • processAllStarts

        public void processAllStarts()
        Description copied from interface: Barrier
        Process all left traversers by do not yield the resultant output. This method is useful for steps like ReducingBarrierStep, where traversers can be processed "on the fly" and thus, reduce memory consumption.
        Specified by:
        processAllStarts in interface Barrier
      • hasNextBarrier

        public boolean hasNextBarrier()
        Description copied from interface: Barrier
        Whether or not the step has an accessible barrier.
        Specified by:
        hasNextBarrier in interface Barrier
        Returns:
        whether a barrier exists or not
      • addBarrier

        public void addBarrier​(Object barrier)
        Description copied from interface: Barrier
        Add a barrier to the step. This typically happens when multiple parallel barriers need to become one barrier at a single step.
        Specified by:
        addBarrier in interface Barrier
        Parameters:
        barrier - the barrier to merge in
      • done

        public void done()
        Description copied from interface: Barrier
        A way to hard set that the barrier is complete. This is necessary when parallel barriers don't all have barriers and need hard resetting. The default implementation does nothing.
        Specified by:
        done in interface Barrier