All Implemented Interfaces:: ai.platon.pulsar.crawl.Crawler , java.lang.AutoCloseable


public class StreamingCrawler<T extends UrlAware>
extends AbstractCrawler

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`public class`	`StreamingCrawler.Companion`

Field Summary

Fields
Modifier and Type	Field	Description
`private final Integer`	`numPrivacyContexts`
`private final Integer`	`numMaxActiveTabs`
`private final Integer`	`fetchConcurrency`
`private final Duration`	`outOfWorkTimeout`
`private final Duration`	`fetchTaskTimeout`
`private final Duration`	`idleTime`
`private final Boolean`	`isOutOfWork`
`private final Boolean`	`isActive`
`private String`	`jobName`
`private Sequence<T>`	`urls`
`private final GlobalCacheFactory`	`globalCacheFactory`
`private final CrawlEventHandler`	`crawlEventHandler`
`private final Boolean`	`noProxy`
`private final Integer`	`id`
`private final String`	`name`
`private Function2<Integer, UrlAware, Duration>`	`retryDelayPolicy`
`private final AtomicBoolean`	`closed`
`private final PulsarSession`	`session`
`private final LoadOptions`	`defaultOptions`
`private final Boolean`	`autoClose`
`private final String`	`defaultArgs`

Constructor Summary

Constructors
Constructor	Description
`StreamingCrawler(Sequence<T> urls, LoadOptions defaultOptions, PulsarSession session, GlobalCacheFactory globalCacheFactory, CrawlEventHandler crawlEventHandler, Boolean noProxy, Boolean autoClose)`

Method Summary

Modifier and Type	Method	Description
`final Integer`	`getNumPrivacyContexts()`
`final Integer`	`getNumMaxActiveTabs()`
`final Integer`	`getFetchConcurrency()`
`final Duration`	`getOutOfWorkTimeout()`
`final Duration`	`getFetchTaskTimeout()`
`final Duration`	`getIdleTime()`
`final Boolean`	`getIsOutOfWork()`
`Boolean`	`getIsActive()`
`final String`	`getJobName()`
`final Unit`	`setJobName(String jobName)`
`final Sequence<T>`	`getUrls()`	The url sequence
`final Unit`	`setUrls(Sequence<T> urls)`	The url sequence
`final GlobalCacheFactory`	`getGlobalCacheFactory()`	An optional global cache which will hold the retry tasks
`final CrawlEventHandler`	`getCrawlEventHandler()`	The crawl event handler
`final Boolean`	`getNoProxy()`	Do not use proxy
`Integer`	`getId()`	The crawl id
`String`	`getName()`
`Function2<Integer, UrlAware, Duration>`	`getRetryDelayPolicy()`	Delay policy for retry tasks
`Unit`	`setRetryDelayPolicy(Function2<Integer, UrlAware, Duration> retryDelayPolicy)`	Delay policy for retry tasks
`final AtomicBoolean`	`getClosed()`
`final PulsarSession`	`getSession()`
`LoadOptions`	`getDefaultOptions()`	The default load options
`final Boolean`	`getAutoClose()`
`String`	`getDefaultArgs()`
`Unit`	`run()`
`Unit`	`run(CoroutineScope scope)`
`Unit`	`await()`	Await for all tasks be done
`final Unit`	`quit()`

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

Constructor Detail

StreamingCrawler

StreamingCrawler(Sequence<T> urls, LoadOptions defaultOptions, PulsarSession session, GlobalCacheFactory globalCacheFactory, CrawlEventHandler crawlEventHandler, Boolean noProxy, Boolean autoClose)

Method Detail

getNumPrivacyContexts
```
 final Integer getNumPrivacyContexts()
```

getNumMaxActiveTabs
```
 final Integer getNumMaxActiveTabs()
```

getFetchConcurrency
```
 final Integer getFetchConcurrency()
```

getOutOfWorkTimeout
```
 final Duration getOutOfWorkTimeout()
```

getFetchTaskTimeout
```
 final Duration getFetchTaskTimeout()
```

getIdleTime
```
 final Duration getIdleTime()
```

getIsOutOfWork
```
 final Boolean getIsOutOfWork()
```

getIsActive
```
 Boolean getIsActive()
```

getJobName
```
 final String getJobName()
```

setJobName
```
 final Unit setJobName(String jobName)
```

getUrls
```
 final Sequence<T> getUrls()
```
The url sequence

setUrls
```
 final Unit setUrls(Sequence<T> urls)
```
The url sequence

getGlobalCacheFactory
```
 final GlobalCacheFactory getGlobalCacheFactory()
```
An optional global cache which will hold the retry tasks

getCrawlEventHandler

 final CrawlEventHandler getCrawlEventHandler()

The crawl event handler

getNoProxy
```
 final Boolean getNoProxy()
```
Do not use proxy

getId
```
 Integer getId()
```
The crawl id

getName
```
 String getName()
```

getRetryDelayPolicy

 Function2<Integer, UrlAware, Duration> getRetryDelayPolicy()

Delay policy for retry tasks

setRetryDelayPolicy

 Unit setRetryDelayPolicy(Function2<Integer, UrlAware, Duration> retryDelayPolicy)

Delay policy for retry tasks

getClosed
```
 final AtomicBoolean getClosed()
```

getSession
```
 final PulsarSession getSession()
```

getDefaultOptions
```
 LoadOptions getDefaultOptions()
```
The default load options

getAutoClose
```
 final Boolean getAutoClose()
```

getDefaultArgs
```
 String getDefaultArgs()
```

run
```
 Unit run()
```

run
```
 Unit run(CoroutineScope scope)
```

await
```
 Unit await()
```
Await for all tasks be done

quit
```
 final Unit quit()
```

Class StreamingCrawler

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class ai.platon.pulsar.crawl.StreamingCrawler

Methods inherited from class java.lang.Object

Constructor Detail

StreamingCrawler

Method Detail

getNumPrivacyContexts

getNumMaxActiveTabs

getFetchConcurrency

getOutOfWorkTimeout

getFetchTaskTimeout

getIdleTime

getIsOutOfWork

getIsActive

getJobName

setJobName

getUrls

setUrls

getGlobalCacheFactory

getCrawlEventHandler

getNoProxy

getId

getName

getRetryDelayPolicy

setRetryDelayPolicy

getClosed

getSession

getDefaultOptions

getAutoClose

getDefaultArgs

run

run

await

quit