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


public class StreamingCrawlLoop
extends AbstractCrawlLoop

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)`

Modifier and Type	Method	Description
`final Boolean`	`getIsRunning()`
`UrlFeeder`	`getUrlFeeder()`	The fetch iterable from which all fetch tasks are taken
`Crawler`	`getCrawler()`
`Integer`	`getId()`
`List<PriorityDataCollector<UrlAware>>`	`getCollectors()`
`String`	`getAbstract()`
`String`	`getReport()`
`String`	`getName()`
`ImmutableConfig`	`getConfig()`
`Unit`	`start()`
`Unit`	`stop()`
`Unit`	`await()`

Methods inherited from class ai.platon.pulsar.crawl.CrawlLoop
restart
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

StreamingCrawlLoop(ImmutableConfig unmodifiedConfig, String name)

getUrlFeeder
```
 UrlFeeder getUrlFeeder()
```
The fetch iterable from which all fetch tasks are taken

 List<PriorityDataCollector<UrlAware>> getCollectors()

Class StreamingCrawlLoop