Class StreamingTaskLoop

  • All Implemented Interfaces:
    ai.platon.pulsar.common.StartStopRunnable , ai.platon.pulsar.skeleton.crawl.TaskLoop , java.lang.AutoCloseable

    
    public class StreamingTaskLoop
    extends AbstractTaskLoop
                        
    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
    • Constructor Summary

      Constructors 
      Constructor Description
      StreamingTaskLoop(ImmutableConfig configuration, String name)
    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description
    • Method Summary

      Modifier and Type Method Description
      TaskRunner getTaskRunner()
      UrlFeeder getUrlFeeder() The url feeder is used by the crawl loop to feed urls to the crawler.
      String getAbstract()
      String getReport()
      Unit start()
      Unit stop()
      Unit await() Wait until the loop is started and all tasks are done.
      • Methods inherited from class ai.platon.pulsar.skeleton.crawl.impl.AbstractTaskLoop

        getCollectors, getConfig, getDisplay, getId, getName, isRunning
      • Methods inherited from class ai.platon.pulsar.common.StartStopRunnable

        close, restart
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait