Package com.norconex.crawler.core.cluster.pipeline

Class BaseStep

java.lang.Object
com.norconex.crawler.core.cluster.pipeline.BaseStep
All Implemented Interfaces:
Step
Direct Known Subclasses:
CrawlerProcessStep, RequeueOrphansForDeletionStep, RequeueOrphansForProcessingStep, StartRefsQueueStep
public abstract class BaseStep extends Object implements Step

  • Constructor Details

    • BaseStep

      public BaseStep(String id)

  • Method Details

    • stop

      public void stop(CrawlerSession session)
      Description copied from interface: Step
      Requests for the step to stop. The method may return before the step is actually stopped (up to implementation).
      Specified by:
      stop in interface Step
      Parameters:
      session - crawl session

    • reduce

      public PipelineStatus reduce(CrawlerSession session, org.apache.commons.collections4.Bag<PipelineStatus> statuses)
      Specified by:
      reduce in interface Step

    • getId

      public String getId()
      Specified by:
      getId in interface Step

    • isDistributed

      public boolean isDistributed()
      Specified by:
      isDistributed in interface Step

    • setDistributed

      public BaseStep setDistributed(boolean distributed)
      Returns:
      this.

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • isStopRequested

      public boolean isStopRequested()
      Description copied from interface: Step
      Indicates whether this step has been asked to stop.

      Default implementation returns false so non BaseStep implementations are not forced to expose internal state.

      Specified by:
      isStopRequested in interface Step
      Returns:
      true if a stop was requested