All Implemented Interfaces:: ai.platon.pulsar.common.StartStopRunnable , ai.platon.pulsar.crawl.CrawlLoop


public class StreamingCrawlLoop
extends AbstractCrawlLoop

Nested Classes
Modifier and Type	Class	Description

Fields
Modifier and Type	Field	Description
`private final Boolean`	`isRunning`
`private final UrlFeeder`	`urlFeeder`
`private final Crawler`	`crawler`
`private final Integer`	`id`
`private final List<PriorityDataCollector<UrlAware>>`	`collectors`
`private final String`	`abstract`
`private final String`	`report`
`private final String`	`name`
`private final ImmutableConfig`	`config`

Constructors
Constructor	Description
`StreamingCrawlLoop(ImmutableConfig unmodifiedConfig, String name)`

Enum Constants
Enum Constant	Description

Modifier and Type	Method	Description
`final Boolean`	`isRunning()`
`UrlFeeder`	`getUrlFeeder()`	The fetch iterable from which all fetch tasks are taken
`Crawler`	`getCrawler()`
`Unit`	`start()`
`Unit`	`stop()`
`Unit`	`await()`	Wait until the loop is started and all tasks are done.

Methods inherited from class ai.platon.pulsar.crawl.impl.AbstractCrawlLoop
getAbstract, getCollectors, getConfig, getId, getName, getReport
Methods inherited from class ai.platon.pulsar.common.StartStopRunnable
restart
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

StreamingCrawlLoop(ImmutableConfig unmodifiedConfig, String name)

Class StreamingCrawlLoop