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.txt files.
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
 
A  B  C  D  E  F  G  H  I  J  K  L  M  N  O  P  Q  R  S  T  U  V  W  _