A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
Q
R
S
T
U
V
W
_
R
- rBadModTime - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rCreated - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rDay0 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay1 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay2 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay3 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay4 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay5 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay6 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDay7 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDayN - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDepth0 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDepth1 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDepth2 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDepth3 - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDepthN - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rDepthUp - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rDetail - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- readAllLines(java.lang.String) - function in ai.platon.pulsar.common.MultiSinkWriter
- readFields(java.io.DataInput) - function in ai.platon.pulsar.crawl.index.IndexField
- readFields(java.io.DataInput) - function in ai.platon.pulsar.crawl.index.io.IndexDocumentWritable
- readFields(java.io.DataInput) - function in ai.platon.pulsar.crawl.scoring.io.ScoreVectorWritable
- READY - enum entry in ai.platon.pulsar.crawl.fetch.FetchTask.State
- READY - enum entry in ai.platon.pulsar.crawl.fetch.driver.WebDriver.State
- Record - class in ai.platon.pulsar.common.message
- ReducerContext - class in ai.platon.pulsar.common
- Created by vincent on 16-9-24.
- refExtractErrDensity - enum entry in ai.platon.pulsar.crawl.scoring.Name
- refFetchErrDensity - enum entry in ai.platon.pulsar.crawl.scoring.Name
- refIndexErrDensity - enum entry in ai.platon.pulsar.crawl.scoring.Name
- refParseErrDensity - enum entry in ai.platon.pulsar.crawl.scoring.Name
- refresh(java.lang.String) - function in ai.platon.pulsar.crawl.fetch.driver.NavigateEntry
- Refresh the entry with the given action.
- RegexHyperlinkExtractor - class in ai.platon.pulsar.common.collect
- register(java.lang.Class,java.lang.String,java.lang.Boolean) - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- register(java.lang.Object,java.lang.String,T) - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- register(java.lang.Object,java.lang.String,java.lang.String,T) - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- register(kotlin.reflect.KClass,java.lang.String,java.lang.Boolean) - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- register(java.lang.Class) - function in ai.platon.pulsar.common.metrics.EnumCounterRegistry
- Register a counter, return the group id of this counter
- register(kotlin.reflect.KClass) - function in ai.platon.pulsar.common.metrics.EnumCounterRegistry
- register(java.lang.Class) - function in ai.platon.pulsar.common.metrics.EnumCounterRegistry.Companion
- register(java.lang.String,T) - function in com.codahale.metrics.MetricRegistry
- registerAll(java.lang.Object,java.lang.String,java.util.Map) - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- registerAll(java.lang.Object,java.util.Map) - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- registerAll(com.codahale.metrics.MetricSet) - function in com.codahale.metrics.MetricRegistry
- registerAll(java.lang.String,com.codahale.metrics.MetricSet) - function in com.codahale.metrics.MetricRegistry
- registerClosable(java.lang.AutoCloseable) - function in ai.platon.pulsar.context.PulsarContext
- Register close objects, the objects will be closed when the context closes
- registerClosable(java.lang.AutoCloseable) - function in ai.platon.pulsar.context.support.AbstractPulsarContext
- Register close objects, the objects will be closed when the context closes
- registerClosable(java.lang.AutoCloseable) - function in ai.platon.pulsar.context.support.AbstractPulsarContext
- Register close objects, the objects will be closed when the context closes
- registerClosable(java.lang.AutoCloseable) - function in ai.platon.pulsar.session.AbstractPulsarSession
- Close objects when the session closes
- registerClosable(java.lang.AutoCloseable) - function in ai.platon.pulsar.session.AbstractPulsarSession
- Close objects when the session closes
- registerClosable(java.lang.AutoCloseable) - function in ai.platon.pulsar.session.PulsarSession
- Close objects when the session closes
- registerFeedThread(ai.platon.pulsar.crawl.fetch.batch.FeedLoop) - function in ai.platon.pulsar.crawl.fetch.batch.FetchMonitor
- registerFetchLoop(ai.platon.pulsar.crawl.fetch.batch.FetchLoop) - function in ai.platon.pulsar.crawl.fetch.batch.FetchMonitor
- registerShutdownHook() - function in ai.platon.pulsar.context.PulsarContext
- Register shutdown hook
- registerShutdownHook() - function in ai.platon.pulsar.context.support.AbstractPulsarContext
- Register a shutdown hook with the JVM runtime, closing this context on JVM shutdown unless it has already been closed at that time.
- registerShutdownHook() - function in ai.platon.pulsar.context.support.AbstractPulsarContext
- Register a shutdown hook with the JVM runtime, closing this context on JVM shutdown unless it has already been closed at that time.
- REJECTED - enum entry in ai.platon.pulsar.common.domain.DomainSuffix.Status
- reload(ai.platon.pulsar.common.config.ImmutableConfig) - function in ai.platon.pulsar.common.MimeTypeResolver
- remove(ai.platon.pulsar.common.urls.FatLink) - function in ai.platon.pulsar.common.collect.HyperlinkCollector
- remove(ai.platon.pulsar.common.urls.FatLink) - function in ai.platon.pulsar.common.collect.HyperlinkCollector
- remove(java.lang.String) - function in ai.platon.pulsar.common.collect.HyperlinkCollector
- remove(java.lang.String) - function in ai.platon.pulsar.common.collect.HyperlinkCollector
- remove(java.lang.Object) - function in ai.platon.pulsar.common.lang.AbstractChainedFunction0
- remove(java.lang.Object) - function in ai.platon.pulsar.common.lang.AbstractChainedFunction1
- remove(java.lang.Object) - function in ai.platon.pulsar.common.lang.AbstractChainedFunction2
- remove(java.lang.Object) - function in ai.platon.pulsar.common.lang.AbstractChainedPDFunction2
- remove(java.lang.String) - function in ai.platon.pulsar.crawl.common.FetchingCache
- remove(java.lang.Integer,java.lang.CharSequence) - function in ai.platon.pulsar.crawl.common.WeakPageIndexer
- remove(java.lang.String) - function in ai.platon.pulsar.crawl.common.WeakPageIndexer
- remove(ai.platon.pulsar.crawl.fetch.batch.TaskScheduler) - function in ai.platon.pulsar.crawl.fetch.batch.TaskSchedulers
- remove(java.lang.Integer) - function in ai.platon.pulsar.crawl.fetch.batch.TaskSchedulers
- remove(ai.platon.pulsar.crawl.fetch.batch.TaskPool) - function in ai.platon.pulsar.crawl.fetch.batch.data.PoolQueue
- remove(kotlin.reflect.KClass) - function in ai.platon.pulsar.crawl.parse.ParseFilters
- remove(java.lang.String) - function in com.codahale.metrics.MetricRegistry
- remove(java.util.concurrent.Delayed) - function in java.util.AbstractCollection
- remove() - function in java.util.AbstractQueue
- remove() - function in java.util.AbstractQueue
- removeAll(java.lang.Iterable) - function in ai.platon.pulsar.common.collect.CrawlableFatLinkCollector
- removeAll(java.util.List) - function in ai.platon.pulsar.common.collect.CrawlableFatLinkCollector
- removeAll(java.lang.Iterable) - function in ai.platon.pulsar.crawl.common.FetchingCache
- removeAll(java.lang.Integer,java.lang.Iterable) - function in ai.platon.pulsar.crawl.common.WeakPageIndexer
- removeAll(java.lang.Iterable) - function in ai.platon.pulsar.crawl.common.WeakPageIndexer
- removeAll(java.lang.String) - function in ai.platon.pulsar.crawl.fetch.driver.NavigateHistory
- removeAll(kotlin.text.Regex) - function in ai.platon.pulsar.crawl.fetch.driver.NavigateHistory
- removeAll(java.util.Collection) - function in java.util.AbstractCollection
- removeAll(java.util.Collection) - function in java.util.AbstractCollection
- removeField(java.lang.CharSequence) - function in ai.platon.pulsar.crawl.index.IndexDocument
- removeIf(java.util.function.Predicate) - function in kotlin.collections.MutableCollection
- removeIf(java.util.function.Predicate) - function in kotlin.collections.MutableCollection
- removeListener(com.codahale.metrics.MetricRegistryListener) - function in com.codahale.metrics.MetricRegistry
- removeMatching(com.codahale.metrics.MetricFilter) - function in com.codahale.metrics.MetricRegistry
- removePDCache(java.lang.String) - function in ai.platon.pulsar.crawl.common.GlobalCache
- Remove items specified by the url from page cache and document cache.
- report(java.util.SortedMap,java.util.SortedMap,java.util.SortedMap,java.util.SortedMap,java.util.SortedMap) - function in ai.platon.pulsar.common.metrics.CodahaleSlf4jReporter
- report() - function in ai.platon.pulsar.crawl.component.InjectComponent
- report() - function in ai.platon.pulsar.crawl.fetch.batch.TaskMonitor
- report() - function in ai.platon.pulsar.crawl.fetch.privacy.PrivacyContext
- report(kotlin.text.StringBuilder) - function in ai.platon.pulsar.crawl.parse.ParseFilters
- report() - function in com.codahale.metrics.ScheduledReporter
- reportBadModifiedTime(java.lang.String) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportBrokenEntity(java.lang.String,java.lang.String) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportDOMStatistics(ai.platon.pulsar.persist.WebPage,ai.platon.pulsar.persist.model.DomStatistics) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportFetchSchedule(ai.platon.pulsar.persist.WebPage,java.lang.Boolean) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportFlawParsedPage(ai.platon.pulsar.persist.WebPage,java.lang.Boolean) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportForceRefetchSeeds(java.lang.String) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportGeneratedHosts(java.util.Set) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportKeys() - function in ai.platon.pulsar.crawl.index.IndexerMapping
- reportLabeledHyperlinks(java.util.Set) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportPerformance(java.lang.String,java.lang.String) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reportRedirects(java.lang.String) - function in ai.platon.pulsar.common.message.MiscMessageWriter
- reset() - function in ai.platon.pulsar.common.metrics.EnumCounterRegistry
- reset() - function in ai.platon.pulsar.common.metrics.MultiMetric
- reset() - function in ai.platon.pulsar.crawl.fetch.FetchTask
- reset() - function in ai.platon.pulsar.crawl.fetch.privacy.PrivacyManager
- Reset the privacy environment, close all privacy contexts, so all fetch tasks are handled by new browser contexts.
- reset() - function in ai.platon.pulsar.crawl.index.IndexField
- reset(ai.platon.pulsar.persist.WebPage) - function in ai.platon.pulsar.crawl.parse.LinkFilter
- reset() - function in ai.platon.pulsar.crawl.parse.html.HTMLMetaTags
- Sets all boolean values to
false. - reset() - function in ai.platon.pulsar.crawl.protocol.Protocol
- Reset the protocol environment, so the peer host view the client as a new one
- reset() - function in ai.platon.pulsar.crawl.protocol.http.AbstractHttpProtocol
- Reset the protocol environment, so the peer host view the client as a new one
- reset() - function in ai.platon.pulsar.crawl.protocol.http.AbstractHttpProtocol
- Reset the protocol environment, so the peer host view the client as a new one
- resetCaches() - function in ai.platon.pulsar.crawl.common.GlobalCache
- Reset all caches.
- resetDailyCounters() - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- resetHourlyCounters() - function in ai.platon.pulsar.common.metrics.AppMetricRegistry
- resolveEncodingAlias(java.lang.String) - function in ai.platon.pulsar.common.EncodingDetector
- Response - class in ai.platon.pulsar.crawl.protocol
- A response interface.
- restart() - function in ai.platon.pulsar.common.CrawlLoop
- restart() - function in ai.platon.pulsar.common.StartStopRunnable
- resume() - function in ai.platon.pulsar.crawl.Crawler
- resume() - function in ai.platon.pulsar.crawl.impl.AbstractCrawler
- resume() - function in ai.platon.pulsar.crawl.impl.AbstractCrawler
- resume() - function in java.lang.Thread
- retainAll(java.util.Collection) - function in java.util.AbstractCollection
- retainAll(java.util.Collection) - function in java.util.AbstractCollection
- retire() - function in ai.platon.pulsar.crawl.fetch.batch.TaskPool
- retire() - function in ai.platon.pulsar.crawl.fetch.driver.AbstractWebDriver
- Mark the driver as retired, so it can not be used to fetch any page, and should be quit as soon as possible.
- retire() - function in ai.platon.pulsar.crawl.fetch.driver.WebDriver
- Mark the driver as retired, so it can not be used to fetch any page, and should be quit as soon as possible.
- retire() - function in ai.platon.pulsar.crawl.fetch.driver.WebDriver
- Mark the driver as retired, so it can not be used to fetch any page, and should be quit as soon as possible.
- RETIRED - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskPool.Status
- RETIRED - enum entry in ai.platon.pulsar.crawl.fetch.driver.WebDriver.State
- retry(ai.platon.pulsar.persist.RetryScope,java.lang.String) - function in ai.platon.pulsar.crawl.fetch.FetchResult
- retry(ai.platon.pulsar.crawl.fetch.FetchTask,ai.platon.pulsar.persist.RetryScope,java.lang.String) - function in ai.platon.pulsar.crawl.fetch.FetchResult.Companion
- retry(ai.platon.pulsar.persist.WebPage,ai.platon.pulsar.persist.RetryScope,kotlin.Exception) - function in ai.platon.pulsar.crawl.protocol.ForwardingResponse.Companion
- retry(ai.platon.pulsar.persist.WebPage,ai.platon.pulsar.persist.RetryScope,java.lang.String) - function in ai.platon.pulsar.crawl.protocol.ForwardingResponse.Companion
- reversed() - function in java.util.Comparator
- reverseOrder() - function in java.util.Comparator
- rFinishedTasks - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rIndexed - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rInlinks - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rLinks - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rLoaded - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rMbps - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rMbytes - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rNewDetail - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rNoParse - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rNotExist - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rNotIndexed - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- RobotRules - class in ai.platon.pulsar.crawl.protocol
- This class holds the rules which were parsed from a robots.txt file, and can test paths against those rules.
- RobotRulesParser - class in ai.platon.pulsar.crawl.protocol
- This class uses crawler-commons for handling the parsing of
robots.txtfiles. - RobotRulesParser.Companion - class in ai.platon.pulsar.crawl.protocol.RobotRulesParser
- rParseFailed - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rPassed - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- rPendingTasks - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rPersist - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rPgps - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rReadyTasks - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rRedirect - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rRows - enum entry in ai.platon.pulsar.common.metrics.CommonCounter
- rSeeds - enum entry in ai.platon.pulsar.crawl.fetch.batch.TaskScheduler.Companion.Counter
- rTotalUpdates - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter
- run() - function in ai.platon.pulsar.common.metrics.EnumCounterReporter
- run(ai.platon.pulsar.crawl.fetch.FetchTask,kotlin.coroutines.SuspendFunction2) - function in ai.platon.pulsar.crawl.fetch.privacy.PrivacyContext
- Run a task in the privacy context and record the status.
- run() - function in ai.platon.pulsar.crawl.fetch.privacy.PrivacyContextMonitor
- run(ai.platon.pulsar.crawl.fetch.FetchTask,kotlin.coroutines.SuspendFunction2) - function in ai.platon.pulsar.crawl.fetch.privacy.PrivacyManager
- Run a task in a privacy context.
- run() - function in ai.platon.pulsar.crawl.impl.StreamingCrawler
- Run the crawler.
- run(kotlinx.coroutines.CoroutineScope) - function in ai.platon.pulsar.crawl.impl.StreamingCrawler
- Run the crawler in the given coroutine scope.
- run() - function in ai.platon.pulsar.crawl.index.jit.indexer.IndexThread
- runAfterBoth(java.util.concurrent.CompletionStage,java.lang.Runnable) - function in java.util.concurrent.CompletableFuture
- runAfterBothAsync(java.util.concurrent.CompletionStage,java.lang.Runnable) - function in java.util.concurrent.CompletableFuture
- runAfterBothAsync(java.util.concurrent.CompletionStage,java.lang.Runnable,java.util.concurrent.Executor) - function in java.util.concurrent.CompletableFuture
- runAfterEither(java.util.concurrent.CompletionStage,java.lang.Runnable) - function in java.util.concurrent.CompletableFuture
- runAfterEitherAsync(java.util.concurrent.CompletionStage,java.lang.Runnable) - function in java.util.concurrent.CompletableFuture
- runAfterEitherAsync(java.util.concurrent.CompletionStage,java.lang.Runnable,java.util.concurrent.Executor) - function in java.util.concurrent.CompletableFuture
- rUpdated - enum entry in ai.platon.pulsar.crawl.component.UpdateComponent.Companion.Counter