ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newCandidate(String)
ContentFetcher.FetchContext.newContent(Supplier)
ContentFetcher.FetchContext.newContent(Supplier)
ContentFetcher.FetchContext.newContent(Supplier)
ContentFetcher.FetchContext.newDelete()
ContentFetcher.FetchContext.newDelete(String)
ContentFetcher.FetchContext.newDelete()
ContentFetcher.FetchContext.newDelete(String)
ContentFetcher.FetchContext.newDocument()
ContentFetcher.FetchContext.newDocument(String)
ContentFetcher.FetchContext.newDocument()
ContentFetcher.FetchContext.newError()
ContentFetcher.FetchContext.newError(String)
ContentFetcher.FetchContext.newSkip()
ContentFetcher.FetchContext.newSkip(String)
ContentFetcher.FetchContext.newSkip(String)
Fetcher.fetch(FetcherContext.FetchContext)
FetchResult.FetchResult(String)
instead.MapBuilder
consumer.MapBuilder
consumer.Callable
with the context of the retry.PostFetchResult.withPurgeStrayItems()
Map
object which is to be indexed in solr.MapBuilder.values
Ignores values that is not accepted by solr like nested map.MapBuilder
consumer.MapBuilder
consumer.ContentFetcher.FetchContext.newCheckpoint(String)
gets id from FetchInputContentFetcher.FetchContext.newContent(String, Supplier)
gets id from FetchInputContentFetcher.FetchContext.newDelete(String)
gets id from FetchInputContentFetcher.FetchContext.newDocument(String)
gets id from FetchInputContentFetcher.FetchContext.newSkip(String)
gets id from FetchInputFetcher.postFetch(FetcherContext.PostFetchContext)
Fetcher.preFetch(FetcherContext.PreFetchContext)
ConnectorPluginProperties
implementation.ConnectorPluginProperties
implementation.CheckedRunnable
with the context of the retry.StaticSecurityConfig
* #DynamicSecurityConfig
FetchResult.FetchResult(String)
instead.Fetcher.start(FetcherContext.StartContext)
DynamicSecurityConfig
.Fetcher.stop(FetcherContext.StopContext)
ValidationContext
class, primarily provides the configuration to be validated.ConnectorPlugin.FetcherDef
and adds it to ConnectorPlugin.Builder.fetcherDefs
FetchInput.Builder.fields(Consumer)
FetchInput.Builder.metadata(Consumer)