Index

A B C D E F G H I J L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbortPolicy() - Constructor for class com.lucidworks.apollo.component.DefaultExecutorComponent.AbortPolicy

Creates an AbortPolicy.

AbstractCachingClient<T> - Class in com.lucidworks.apollo.pipeline.events

AbstractCachingClient(FusionResourceType, EventSubscriber<FusionCrudEvent>) - Constructor for class com.lucidworks.apollo.pipeline.events.AbstractCachingClient

AbstractCachingClient(FusionResourceType, EventSubscriber<FusionCrudEvent>, CacheBuilder<Object, Object>) - Constructor for class com.lucidworks.apollo.pipeline.events.AbstractCachingClient

AbstractCall - Class in com.lucidworks.cloud.api.call

AbstractCall() - Constructor for class com.lucidworks.cloud.api.call.AbstractCall

AbstractCrudEntityValidator<E extends com.lucidworks.apollo.common.objects.Entity> - Interface in com.lucidworks.apollo.resources.validators

provide validation logic for entities that are used by the AbstractCrudResource that cannot be achieved with existing schema validation facilities.

AbstractGenerator<M,C extends com.lucidworks.apollo.pipeline.StageConfig> - Class in com.lucidworks.apollo.pipeline

AbstractGenerator() - Constructor for class com.lucidworks.apollo.pipeline.AbstractGenerator

AbstractPipelineDefinitionStore<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> - Class in com.lucidworks.apollo.pipeline.impl

Bridge between PipelineDefinitionRegistry and ItemStore

AbstractPipelineDefinitionStore(CuratorFramework, MetricRegistry, String, ItemReader<T>, ItemWriter<T>) - Constructor for class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

AbstractPipelineManager<M> - Class in com.lucidworks.apollo.pipeline

Manages the set of currently known Pipelines TODO extract an interface for the history stuff, store history in Solr

AbstractPipelineManager(PipelineDefinitionRegistry, MetricRegistry, StageFactory<M>, ConfigurationComponent) - Constructor for class com.lucidworks.apollo.pipeline.AbstractPipelineManager

AbstractProcessor<M,C extends com.lucidworks.apollo.pipeline.StageConfig> - Class in com.lucidworks.apollo.pipeline

AbstractProcessor() - Constructor for class com.lucidworks.apollo.pipeline.AbstractProcessor

AbstractStage<M,C extends com.lucidworks.apollo.pipeline.StageConfig> - Class in com.lucidworks.apollo.pipeline

AbstractStage() - Constructor for class com.lucidworks.apollo.pipeline.AbstractStage

add(String, Collection<SolrInputDocument>, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

add(String, SolrInputDocument, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

add(Collection<SolrInputDocument>) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

add(Collection<SolrInputDocument>, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

add(SolrInputDocument, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

ADD - Enum constant in enum class com.lucidworks.apollo.component.BufferingSolrServer.Action

addCollectionChangeListener(CollectionComponent.CollectionChangeAware) - Method in class com.lucidworks.apollo.component.CollectionComponent

addContentStream(ContentStream) - Method in class com.lucidworks.cloud.api.call.impl.SolrPayloadRequest

addDetail(String, Object) - Method in class com.lucidworks.apollo.common.models.HistoryEvent

Note that this isn't synchronized; callers are expected to keep the HistoryEvent within one thread.

addItemHistory(String, String, HistoryEvent) - Method in class com.lucidworks.apollo.common.models.HistoryStore

addItemHistory(String, String, HistoryEvent, Boolean) - Method in class com.lucidworks.apollo.common.models.HistoryStore

addResultsToContext(ResultSet, String, Context) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

addResultsToRequest(ResultSet, String, PipelineDocument) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

addServiceHistory(String, HistoryEvent) - Method in class com.lucidworks.apollo.common.models.HistoryStore

addStateListener(Runnable, Pipeline.State...) - Method in class com.lucidworks.apollo.pipeline.Pipeline

addUpdateAction(Consumer<SearchCluster>) - Method in interface com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClient

Register the listener to get notification about changes.

addUpdateAction(Consumer<SearchCluster>) - Method in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

addValue(Map<String, Object>, String, Object) - Static method in class com.lucidworks.apollo.pipeline.util.RPCUtils

allowCoreThreadTimeOut(boolean) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

AnnotationIndexingUtils - Class in com.lucidworks.apollo.component

AnnotationIndexingUtils() - Constructor for class com.lucidworks.apollo.component.AnnotationIndexingUtils

APP_NAME - Static variable in class com.lucidworks.apollo.component.SystemAppRegistrar

APP_VERSION - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

apply(ItemReadStore.ItemAndVersion<T>) - Method in class com.lucidworks.apollo.pipeline.component.CopySecretsUpdateStrategy

apply(ItemReadStore.ItemAndVersion<T>) - Method in class com.lucidworks.apollo.pipeline.component.StageSchemaValidatingUpdateStrategy

applyRow(Map<String, Object>, ModelServiceOuterClass.Row, String) - Method in class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

AS_RESPONSE - Static variable in class com.lucidworks.apollo.pipeline.util.RPCUtils

asString(Document) - Method in class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom

Serialize a W3C document to a String.

authzSupport(Environment) - Method in class com.lucidworks.cloud.api.call.CallApiConfiguration

AuthzSupport - Class in com.lucidworks.cloud.api.security

AuthzSupport(Environment) - Constructor for class com.lucidworks.cloud.api.security.AuthzSupport

AutoDiscover - Annotation Interface in com.lucidworks.apollo.pipeline

Something that is intended to be auto-discovered by classpath scanning.

B

BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M> - Interface in com.lucidworks.apollo.pipeline

Contract for all components to fulfill basic pipeline requirements.

bindStatement(PreparedStatement, List<String>, Context, PipelineDocument) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

First check the context and then check the field.

BlobFileSystem - Class in com.lucidworks.apollo.util

File system for GraalVM context, allows to import the javascript files from blob store, in a convenient way like from file

BlobFileSystem(ManagedJavascriptSupplier) - Constructor for class com.lucidworks.apollo.util.BlobFileSystem

BlobJavascriptSupplier - Class in com.lucidworks.apollo.pipeline.util

BlobJavascriptSupplier(RestTemplate, String) - Constructor for class com.lucidworks.apollo.pipeline.util.BlobJavascriptSupplier

borrowObject() - Method in class com.lucidworks.apollo.util.SingleValuePool

BufferingSolrServer - Class in com.lucidworks.apollo.component

Simple class that wraps a SolrClient instance and adds a simple buffer on top of it.

BufferingSolrServer(SolrClient, int, long) - Constructor for class com.lucidworks.apollo.component.BufferingSolrServer

BufferingSolrServer(SolrClient, int, long, int, String, String, MetricRegistry, String) - Constructor for class com.lucidworks.apollo.component.BufferingSolrServer

BufferingSolrServer.Action - Enum Class in com.lucidworks.apollo.component

build() - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

Build the ThreadPoolExecutor using the given configuration.

build(CallParams) - Method in interface com.lucidworks.cloud.api.call.CallBuilder

build(CallParams) - Method in class com.lucidworks.cloud.api.call.impl.HttpCallBuilder

build(CallParams) - Method in class com.lucidworks.cloud.api.call.impl.ServiceCallBuilder

Build a ServiceCall from CallParams Service URIs look like service://{service}/{path}.

build(CallParams) - Method in class com.lucidworks.cloud.api.call.impl.SolrCallBuilder

buildCall(CallParams) - Method in class com.lucidworks.cloud.api.call.CallFactory

builder(String, String) - Method in class com.lucidworks.cloud.api.call.CallFactory

buildIsolatedContext() - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

Builds a fully isolated context with maximum security restrictions.

buildSimpleContext() - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

C

Cache(CuratorFramework, MetricRegistry, ObjectMapper, StringDecryptor, SearchClusterStore) - Constructor for class com.lucidworks.apollo.component.SearchClusterStore.Cache

Call - Interface in com.lucidworks.cloud.api.call

An abstract call to a remote endpoint.

CALL_OUTCOME_TOTAL - Static variable in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

CALL_TIME_SECS - Static variable in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

CallApiConfiguration - Class in com.lucidworks.cloud.api.call

CallApiConfiguration() - Constructor for class com.lucidworks.cloud.api.call.CallApiConfiguration

CallBuilder - Interface in com.lucidworks.cloud.api.call

Builds a particular Call implementation.

CallFactory - Class in com.lucidworks.cloud.api.call

This component uses a registry of known Call implementations to create appropriate implementation based on URI scheme.

CallFactory(Set<CallBuilder>) - Constructor for class com.lucidworks.cloud.api.call.CallFactory

CallSpec - Class in com.lucidworks.js.api.client

Part of JavaScript API You can use in a way: function (request, response, ctx) { var spec = callFactory.builder('get', 'service: //admin/something'); spec.entity='body'; resp = JSON.parse(spec.exchange()['entity']); ctx.setProperty('status', resp.status); }

CallSpec(CallFactory) - Constructor for class com.lucidworks.js.api.client.CallSpec

checkAccess(Path, Set<? extends AccessMode>, LinkOption...) - Method in class com.lucidworks.apollo.util.BlobFileSystem

checkAuthorized(HttpAccessRequest) - Method in class com.lucidworks.cloud.api.security.AuthzSupport

checkAuthorized(String, String) - Method in class com.lucidworks.cloud.api.security.AuthzSupport

checkSolrCollectionAndShardsParams(String, String, String, AuthorizationContext) - Method in class com.lucidworks.cloud.api.solr.SolrAuthorizationComponent

clearAllItemHistory(String) - Method in class com.lucidworks.apollo.common.models.HistoryStore

clearAllServiceHistory() - Method in class com.lucidworks.apollo.common.models.HistoryStore

clearItemHistory(String, String) - Method in class com.lucidworks.apollo.common.models.HistoryStore

clearRedactionFromPipeline(T, SchemaProcessorFactory) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

Traverse a Pipeline's stages and their properties, removing "xXx-Redacted-xXx" as they are found.

clearServiceHistory(String) - Method in class com.lucidworks.apollo.common.models.HistoryStore

cloneListeners() - Method in class com.lucidworks.apollo.component.CollectionComponent

close() - Method in class com.lucidworks.apollo.component.BufferingSolrServer

close() - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

close() - Method in class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

close() - Method in class com.lucidworks.apollo.util.SingleValuePool

close() - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent.OverrideCollectionSolrClient

close() - Method in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

collect(String) - Method in interface com.lucidworks.cloud.api.solr.SolrMetricsCollector

Save the response result of current call

collect(String) - Method in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

collectError(Throwable) - Method in interface com.lucidworks.cloud.api.solr.SolrMetricsCollector

Method to store an communication exception class name as the response error.

COLLECTION_CALL_TIME_SECS - Static variable in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

collectionChangeListeners - Variable in class com.lucidworks.apollo.component.CollectionComponent

collectionComponent(CuratorFramework, MetricRegistry, ObjectMapper) - Method in class com.lucidworks.apollo.component.CollectionsConfigurations

CollectionComponent - Class in com.lucidworks.apollo.component

Does basic data reading involving collections.

CollectionComponent(CuratorFramework, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.CollectionComponent

CollectionComponent.CollectionChangeAware - Interface in com.lucidworks.apollo.component

COLLECTIONS_PARAM - Static variable in class com.lucidworks.cloud.api.solr.SolrAuthorizationComponent

CollectionsConfigurations - Class in com.lucidworks.apollo.component

CollectionsConfigurations() - Constructor for class com.lucidworks.apollo.component.CollectionsConfigurations

collectionStore(CuratorFramework, MetricRegistry, ObjectMapper) - Method in class com.lucidworks.apollo.component.CollectionsConfigurations

CollectionStore - Class in com.lucidworks.apollo.component

Store collection metadata in ZooKeeper

CollectionStore(CuratorFramework, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.CollectionStore

collectOK() - Method in interface com.lucidworks.cloud.api.solr.SolrMetricsCollector

Method which should be called if call is successful.

collectWithTime(String, long) - Method in interface com.lucidworks.cloud.api.solr.SolrMetricsCollector

Collect the metric with external timer value.

collectWithTime(String, long) - Method in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

com.lucidworks.apollo.blob.sql - package com.lucidworks.apollo.blob.sql

com.lucidworks.apollo.common.models - package com.lucidworks.apollo.common.models

com.lucidworks.apollo.component - package com.lucidworks.apollo.component

com.lucidworks.apollo.config - package com.lucidworks.apollo.config

com.lucidworks.apollo.links - package com.lucidworks.apollo.links

com.lucidworks.apollo.partitioning - package com.lucidworks.apollo.partitioning

com.lucidworks.apollo.pipeline - package com.lucidworks.apollo.pipeline

com.lucidworks.apollo.pipeline.component - package com.lucidworks.apollo.pipeline.component

com.lucidworks.apollo.pipeline.events - package com.lucidworks.apollo.pipeline.events

com.lucidworks.apollo.pipeline.helper - package com.lucidworks.apollo.pipeline.helper

com.lucidworks.apollo.pipeline.impl - package com.lucidworks.apollo.pipeline.impl

com.lucidworks.apollo.pipeline.index - package com.lucidworks.apollo.pipeline.index

com.lucidworks.apollo.pipeline.util - package com.lucidworks.apollo.pipeline.util

com.lucidworks.apollo.resources - package com.lucidworks.apollo.resources

com.lucidworks.apollo.resources.validators - package com.lucidworks.apollo.resources.validators

com.lucidworks.apollo.rest - package com.lucidworks.apollo.rest

com.lucidworks.apollo.rest.providers - package com.lucidworks.apollo.rest.providers

com.lucidworks.apollo.sql - package com.lucidworks.apollo.sql

com.lucidworks.apollo.store - package com.lucidworks.apollo.store

com.lucidworks.apollo.util - package com.lucidworks.apollo.util

com.lucidworks.cloud.api.call - package com.lucidworks.cloud.api.call

com.lucidworks.cloud.api.call.impl - package com.lucidworks.cloud.api.call.impl

com.lucidworks.cloud.api.security - package com.lucidworks.cloud.api.security

com.lucidworks.cloud.api.solr - package com.lucidworks.cloud.api.solr

com.lucidworks.cloud.api.solr.parser - package com.lucidworks.cloud.api.solr.parser

com.lucidworks.js.api - package com.lucidworks.js.api

This package and its subpackages contain classes and interfaces which are used by JavaScript stages.

com.lucidworks.js.api.client - package com.lucidworks.js.api.client

CompiledScriptPoolFactory - Class in com.lucidworks.apollo.util

CompiledScriptPoolFactory(CompiledScript, Function<ScriptEngine, Bindings>) - Constructor for class com.lucidworks.apollo.util.CompiledScriptPoolFactory

compileScript(ScriptEngine, Function<ScriptEngine, Bindings>, String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

CONDITION_BYPASS - Static variable in class com.lucidworks.apollo.pipeline.FusionMetricConstants

collected when the condition for a stage is bypassed - due to managed mode enabled

CONDITION_OUTCOME - Static variable in class com.lucidworks.apollo.pipeline.RuntimeStage

ConfigResourceLoaderFactory - Class in com.lucidworks.apollo.config

Load config objects from a system resource Expects a JSON file with an object of objects which map to POJOs

ConfigResourceLoaderFactory(ObjectMapper) - Constructor for class com.lucidworks.apollo.config.ConfigResourceLoaderFactory

ConfigResourceLoaderFactory.ConfigResourceLoader<T> - Class in com.lucidworks.apollo.config

Configurable<C extends com.lucidworks.apollo.pipeline.StageConfig> - Interface in com.lucidworks.apollo.pipeline

Something that can be configured (data source, pipeline stage, aggregation, etc)

ConfigurationComponent - Class in com.lucidworks.apollo.config

ConfigurationComponent() - Constructor for class com.lucidworks.apollo.config.ConfigurationComponent

constructPropertyName(String, String, int) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

Context - Interface in com.lucidworks.js.api

CONTEXT - Static variable in class com.lucidworks.apollo.pipeline.util.RPCUtils

convert(Document, Document) - Method in class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom

Converts a jsoup document into the provided W3C Document.

convertNode(Map<String, Object>, Node, String) - Static method in class com.lucidworks.apollo.pipeline.util.RPCUtils

convertPipelineDocumentToSolr(PipelineDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

convertSolrInputDocumentToPipelineDocument(SolrInputDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

convertTo(Map<String, Object>, String) - Method in class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

copyPipelineSecretsFromOldSelf(T, T) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

Traverse into the Pipeline's stages and copy secrets over from an existing copy.

copyPipelineSecretsFromOldSelf(T, T, ObjectMapper) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

copySecretsFromOther(T, T) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

Copy decrypted secrets from one pipelines to another.

copySecretsFromOther(T, T, ObjectMapper, SchemaProcessorFactory) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

CopySecretsUpdateStrategy<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> - Class in com.lucidworks.apollo.pipeline.component

Copy secrets from another pipeline if PipelineConstants.SECRET_SOURCE_PIPELINE_ID is set

CopySecretsUpdateStrategy(ItemReadWriteStore<T>) - Constructor for class com.lucidworks.apollo.pipeline.component.CopySecretsUpdateStrategy

CopySecretsUpdateStrategy(ItemReadWriteStore<T>, ObjectMapper, SchemaProcessorFactory) - Constructor for class com.lucidworks.apollo.pipeline.component.CopySecretsUpdateStrategy

copyStageSecretsFromOldSelf(ObjectNode, ObjectNode) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

Copy the secrets from oldNode onto newNode, recursively.

counts - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus

create() - Method in class com.lucidworks.apollo.util.CompiledScriptPoolFactory

create() - Method in class com.lucidworks.apollo.util.ValueHolder

create(Pipeline<?>) - Static method in class com.lucidworks.apollo.pipeline.PipelineStatus

create(StageAssistFactoryParams) - Method in interface com.lucidworks.apollo.pipeline.StageAssistFactory

create(Engine, FileSystem) - Method in interface com.lucidworks.apollo.util.GraalVMContextFactory

Creates a GraalVM JavaScript context.

createDirectory(Path, FileAttribute<?>...) - Method in class com.lucidworks.apollo.util.BlobFileSystem

createDocument(Object, String, Context, ObjectMapper) - Static method in class com.lucidworks.apollo.pipeline.util.RPCUtils

createErrorInfo(Throwable) - Static method in exception com.lucidworks.cloud.api.solr.FusionSolrWrapperException

Extract information from Solr exceptions

createIsolatedContext() - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

Creates an isolated context builder with maximum security restrictions.

createMetrics(SolrRequest, String) - Static method in class com.lucidworks.cloud.api.solr.SolrMetricsFactory

Based on the request will return appropriate metrics implementation.

createNashornCompatibleContext() - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

Return the context preconfigured to be compatible with nashorn engine as much as possible.

createNewJavascriptEngine() - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

Creates Javascript Engine.

createResponse(SolrClient) - Method in class com.lucidworks.cloud.api.call.impl.SolrPayloadRequest

createSolrClientForCluster(SearchCluster) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

createStage(String, StageAssistFactoryParams) - Method in interface com.lucidworks.apollo.pipeline.StageFactory

CuratorConfiguration - Class in com.lucidworks.apollo.config

Configuration for Curator framework

CuratorConfiguration() - Constructor for class com.lucidworks.apollo.config.CuratorConfiguration

D

DataSourceDescriptor - Class in com.lucidworks.apollo.sql

DataSourceDescriptor(String, String, String, String, Integer) - Constructor for class com.lucidworks.apollo.sql.DataSourceDescriptor

dataSourceProvider - Variable in class com.lucidworks.apollo.blob.sql.SQLHelper

DataSourceProvider - Interface in com.lucidworks.apollo.sql

manages the creation and caretaking of data sources as described by their descriptors

DecryptingPipelineReader<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> - Class in com.lucidworks.apollo.store

ItemReader that decrypts secrets (e.g.

DecryptingPipelineReader(ObjectMapper, StringDecryptor, Class<T>, SchemaProcessorFactory) - Constructor for class com.lucidworks.apollo.store.DecryptingPipelineReader

DEFAULT_DELIMITER - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

DEFAULT_NASHORN_ENGINE - Static variable in class com.lucidworks.apollo.util.ScriptEngineFactory

DEFAULT_SEARCH_LOGS_COLLECTION_SUFFIX - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

DefaultBasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M> - Class in com.lucidworks.apollo.pipeline

Base implementation of the BasePipelineComponent.

DefaultBasePipelineComponent(ItemReadWriteStore<T>, PipelineManager<M>, ConfigurationComponent) - Constructor for class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

DefaultDocumentAssignmentStrategy - Class in com.lucidworks.apollo.partitioning

Default assignment strategy just selects the configured Solr collection to send documents to, i.e.

DefaultDocumentAssignmentStrategy(String) - Constructor for class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

DefaultExecutorComponent - Class in com.lucidworks.apollo.component

A convenience class for creating executor services.

DefaultExecutorComponent(MetricRegistry) - Constructor for class com.lucidworks.apollo.component.DefaultExecutorComponent

DefaultExecutorComponent.AbortPolicy - Class in com.lucidworks.apollo.component

Just like the java.util.concurrent.ThreadPoolExecutor.AbortPolicy, but with a better error message.

DefaultExecutorComponent.ListeningExecutorServiceBuilder - Class in com.lucidworks.apollo.component

DefaultMessageBodyRedactor<T> - Class in com.lucidworks.apollo.rest.providers

DefaultMessageBodyRedactor(Class<T>) - Constructor for class com.lucidworks.apollo.rest.providers.DefaultMessageBodyRedactor

DefaultMessageBodyRedactor(Class<T>, SchemaProcessorFactory) - Constructor for class com.lucidworks.apollo.rest.providers.DefaultMessageBodyRedactor

DefaultMessageBodyRedactor.SearchClusterMessageBodyRedactor - Class in com.lucidworks.apollo.rest.providers

defaultSplitter - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

delegate - Variable in class com.lucidworks.apollo.component.BufferingSolrServer

delete(Path) - Method in class com.lucidworks.apollo.util.BlobFileSystem

DELETE_BY_ID - Enum constant in enum class com.lucidworks.apollo.component.BufferingSolrServer.Action

DELETE_BY_QUERY - Enum constant in enum class com.lucidworks.apollo.component.BufferingSolrServer.Action

deleteAllPartitions() - Method in class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

deleteAllPartitions() - Method in interface com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy

Delete all partitions created by this strategy.

deleteById(String) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(String, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(String, String) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(String, String, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(String, List<String>) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(String, List<String>, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(List<String>) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteById(List<String>, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteByQuery(String) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteByQuery(String, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteByQuery(String, String) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deleteByQuery(String, String, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

deletePartition(String) - Method in class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

deletePartition(String) - Method in interface com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy

Deletes a partition managed by this strategy.

destroyObject(PooledObject<ValueHolder<Object>>) - Method in class com.lucidworks.apollo.util.CompiledScriptPoolFactory

details - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

DocumentAssignmentStrategy - Interface in com.lucidworks.apollo.partitioning

A strategy for assigning documents to Solr collections.

doScheduledMaintenanceOnPartitions() - Method in class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

doScheduledMaintenanceOnPartitions() - Method in interface com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy

Called in the background at a regular interval to allow the strategy to perform maintenance on the partitions.

E

EncryptingPipelineWriter<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> - Class in com.lucidworks.apollo.store

ItemWriter that encrypts secrets (e.g.

EncryptingPipelineWriter(ObjectMapper, StringEncryptor, Class<T>, SchemaProcessorFactory) - Constructor for class com.lucidworks.apollo.store.EncryptingPipelineWriter

end - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

equals(Object) - Method in class com.lucidworks.apollo.common.models.HistoryEvent

equals(Object) - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

error - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

error - Variable in class com.lucidworks.apollo.util.ValueHolder

escapeKey(String) - Method in class com.lucidworks.apollo.pipeline.AbstractStage

eval(ScriptContext) - Method in class com.lucidworks.apollo.util.NotReallyCompiledScript

Deprecated.

eval(ScriptContext) - Method in class com.lucidworks.apollo.util.ScriptEngineFactory.NotReallyCompiledScript

evaluateConditionalScript(M, Context) - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

exchange() - Method in class com.lucidworks.js.api.client.CallSpec

execute() - Method in class com.lucidworks.cloud.api.call.AbstractCall

execute() - Method in interface com.lucidworks.cloud.api.call.Call

Execute the call and return result

execute() - Method in class com.lucidworks.cloud.api.call.impl.ServiceCall

executeInternal() - Method in class com.lucidworks.cloud.api.call.AbstractCall

executeInternal() - Method in class com.lucidworks.cloud.api.call.impl.HttpCall

executeInternal() - Method in class com.lucidworks.cloud.api.call.impl.SolrCall

executeWithRetries(Class<T>, Object) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

ExecutorComponent - Interface in com.lucidworks.apollo.component

extract(Entity) - Method in interface com.lucidworks.apollo.links.LinkExtractor

Extract links from an Entity

extract(Entity) - Method in class com.lucidworks.apollo.links.SchemaLinkExtractor

extract(FusionResource, Object) - Method in interface com.lucidworks.apollo.links.LinkExtractor

Extract links from source which is represented by sourceResource

extract(FusionResource, Object) - Method in class com.lucidworks.apollo.links.SchemaLinkExtractor

extract(Object, String) - Method in interface com.lucidworks.apollo.links.LinkExtractor

Extract links from an Object

extract(Object, String) - Method in class com.lucidworks.apollo.links.SchemaLinkExtractor

F

factory - Variable in class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom

factory() - Element in annotation interface com.lucidworks.apollo.pipeline.AutoDiscover

Deprecated.

FAILED - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

filterEntityList(List<E>, String) - Method in class com.lucidworks.cloud.api.security.AuthzSupport

Filter entity list based on permissions (if any) defined by the user

finalizeJob(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

finalizeJob(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager

finish() - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator

FINISHED - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

finishedRunnable - Variable in class com.lucidworks.apollo.pipeline.AbstractGenerator

FINISHING - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

flatten(PipelineDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

Flatten the structure of document.

flatten(PipelineDocument, boolean) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

Flatten the structure of document.

flush() - Method in class com.lucidworks.apollo.component.BufferingSolrServer

flushBuffers() - Method in class com.lucidworks.apollo.common.models.HistoryStore

flushBuffers() - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

flushExecutor - Static variable in class com.lucidworks.apollo.component.BufferingSolrServer

This is shared between all BufferingSolrServer instances; they'll each register a scheduled Runnable in here as they start up.

forValue(String) - Static method in enum class com.lucidworks.apollo.pipeline.PipelineStateTransition.State

Deprecated.

fromEventMap(Map<CharSequence, Object>) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

fromJsoup(Document) - Method in class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom

Convert a jsoup Document to a W3C Document.

fromMap(Map<?, ?>) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

fromMap(Map<?, ?>, boolean) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

fromMap(Map<?, ?>, PipelineDocument, boolean) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

fromRow(ModelServiceOuterClass.Row) - Method in class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

fromSolrDocument(SolrDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

FusionCrudEventConfiguration - Class in com.lucidworks.apollo.pipeline.events

FusionCrudEventConfiguration() - Constructor for class com.lucidworks.apollo.pipeline.events.FusionCrudEventConfiguration

fusionCrudEventEventPublisher(KafkaComponent, String) - Method in class com.lucidworks.apollo.pipeline.events.FusionCrudEventConfiguration

fusionCrudEventEventSubscriber(KafkaComponent, ScheduledExecutorService, String) - Method in class com.lucidworks.apollo.pipeline.events.FusionCrudEventConfiguration

FusionMetricConstants - Class in com.lucidworks.apollo.pipeline

convenience constants class to hold metric literals and their descriptions

FusionMetricConstants() - Constructor for class com.lucidworks.apollo.pipeline.FusionMetricConstants

FusionParamReplicaListTransformer - Class in com.lucidworks.cloud.api.solr

FusionParamReplicaListTransformer(String[], ReplicaListTransformer) - Constructor for class com.lucidworks.cloud.api.solr.FusionParamReplicaListTransformer

FusionReplicaListTransformerGenerator - Class in com.lucidworks.cloud.api.solr

Adds the Fusion node filter transformer to a default list of SolrJ transformers.

FusionReplicaListTransformerGenerator() - Constructor for class com.lucidworks.cloud.api.solr.FusionReplicaListTransformerGenerator

FusionSolrWrapperException - Exception in com.lucidworks.cloud.api.solr

Fusion exception which can extract some important information form Solr excepting

FusionSolrWrapperException(SolrServerException) - Constructor for exception com.lucidworks.cloud.api.solr.FusionSolrWrapperException

Deprecated.

FusionSolrWrapperException(SolrException) - Constructor for exception com.lucidworks.cloud.api.solr.FusionSolrWrapperException

Deprecated.

G

Generator<M,C extends com.lucidworks.apollo.pipeline.StageConfig> - Interface in com.lucidworks.apollo.pipeline

A stateful stage that generates documents Since a Generator can stop itself, it adds an onFinished listener

get() - Method in class com.lucidworks.apollo.config.ConfigResourceLoaderFactory.ConfigResourceLoader

get() - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

get(DataSourceDescriptor) - Method in interface com.lucidworks.apollo.sql.DataSourceProvider

retrieve a BasicDataSource instance that fullfills the configuration of the provided DataSourceDescriptor

get(String) - Method in class com.lucidworks.apollo.pipeline.events.AbstractCachingClient

get(String) - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

get(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

get(String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

getAllResourceClients(Class<T>) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getAllResourceClients(Class<T>, MultivaluedMap<String, String>) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getAllResourceClients(String) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getAuthorizationContext() - Method in class com.lucidworks.cloud.api.security.AuthzSupport

getBaseSleepMs() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

The initial sleep in milliseconds before Curator attempts to retry an operation

getBoolean(String, boolean) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getBufferingSolrServer(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getBufferingSolrServer(String, Integer, Long) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getCached(String) - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

getCached(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

getClazz() - Method in class com.lucidworks.apollo.rest.providers.DefaultMessageBodyRedactor

getCloudSolrClient(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getCluster(String) - Method in interface com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClient

getCluster(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

getClusters() - Method in interface com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClient

getClusters() - Method in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

getClustersId() - Method in interface com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClient

getClustersId() - Method in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

getClusterStateProvider() - Method in class com.lucidworks.cloud.api.solr.PipelineCloudSolrClient

getCollection(String) - Method in class com.lucidworks.apollo.component.CollectionComponent

getCollection(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getCollectionFromSignalsCollection(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getCommitWithin(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getCompiledScript(ScriptEngine, String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

getConditionScriptFuncArguments(M, Context) - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getConditionScriptFuncWrapper() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getConfigClass(String) - Method in interface com.lucidworks.apollo.pipeline.StageFactory

getConfiguration() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getConfiguration() - Method in interface com.lucidworks.apollo.pipeline.Configurable

getConfiguration() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getConfigurationComponent() - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

getConfigurationComponent() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getConfigurationComponent() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

getConnection() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

getConnection(DataSourceDescriptor) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

Given a data source description, return a JDBC connection from the cache based off of the DBCP DataSource

getConnectTimeoutMs() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

Timeout in milliseconds for Curator to connect to ZooKeeper

getContentStreams() - Method in class com.lucidworks.cloud.api.call.impl.SolrPayloadRequest

getContentType() - Method in class com.lucidworks.cloud.api.solr.parser.JsonPathResponseParser

getContextFactory() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getContextFactory() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getContextFactory() - Method in interface com.lucidworks.apollo.pipeline.Stage

getContextFactory() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

getCurator(SearchCluster) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getDelegate() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getDelegateConfig() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getDocumentAssignmentStrategy(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getDriver() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

getEngine() - Method in class com.lucidworks.apollo.util.NotReallyCompiledScript

Deprecated.

getEngine() - Method in class com.lucidworks.apollo.util.ScriptEngineFactory.NotReallyCompiledScript

getEntity() - Method in class com.lucidworks.js.api.client.CallSpec

getError() - Method in class com.lucidworks.apollo.util.ValueHolder

getErrors() - Method in class com.lucidworks.apollo.pipeline.Pipeline

Collect errors from the stages

getExecuted() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage.StageExecutionInfo

getHeaders() - Method in class com.lucidworks.js.api.client.CallSpec

getHistoricalJobs(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

getId() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getId() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getId() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage.StageExecutionInfo

getId() - Method in interface com.lucidworks.apollo.pipeline.Stage

getId() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

getInflightMessageCount() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getInitialProperties() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

getInstanceId() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getInt(String, int) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getItem(String) - Method in class com.lucidworks.apollo.component.SearchClusterStore.Cache

getItemHistory(String, String, String, int) - Method in class com.lucidworks.apollo.common.models.HistoryStore

getJavascript(String, String) - Method in class com.lucidworks.apollo.pipeline.util.BlobJavascriptSupplier

getJavascript(String, String) - Method in interface com.lucidworks.apollo.pipeline.util.ManagedJavascriptSupplier

getLbClient() - Method in class com.lucidworks.cloud.api.solr.PipelineCloudSolrClient

getMaxRetries() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

Maximum number of times Curator will retry a failed operation

getMaxSleepMs() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

The maximum sleep in milliseconds between retries for failed operations

getMessageClass() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getMessageClass() - Method in interface com.lucidworks.apollo.pipeline.Stage

getMethod() - Method in class com.lucidworks.js.api.client.CallSpec

getMetricRegistry() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getMetricRegistry() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getMetricRegistry() - Method in interface com.lucidworks.apollo.pipeline.Stage

getMetricRegistry() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

getMetricRegistry() - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getMetrics() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getNamespace() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

getNew(String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

getNewByExtension(String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

getNewByMimeType(String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

getNewByName(String) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

getNext() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getNumberOfRequestsInBuffer() - Method in class com.lucidworks.apollo.component.BufferingSolrServer

getOrCreateCachedThreadPool(String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

getOrCreateCachedThreadPool(String) - Method in interface com.lucidworks.apollo.component.ExecutorComponent

getOrCreateFixedThreadPool(int, String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

getOrCreateFixedThreadPool(int, String) - Method in interface com.lucidworks.apollo.component.ExecutorComponent

getOrCreateJerseyClient() - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getOrCreatePartitionForDoc(PipelineDocument) - Method in class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

getOrCreatePartitionForDoc(PipelineDocument) - Method in interface com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy

Returns the name of a Solr collection where a document should be assigned to based on this strategy.

getOrCreatePipeline(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

getOrCreatePipeline(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager

Return the current pipeline instance for the given id, or create one

getOrCreatePipeline(String, Map<String, String>) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

getOrCreatePipeline(String, Map<String, String>) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager

Deprecated.

getOrCreatePipelineImpl(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

getOrCreateSingleThreadExecutor(String, String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

TODO: experimental.

getOrCreateSingleThreadExecutor(String, String) - Method in interface com.lucidworks.apollo.component.ExecutorComponent

getOrCreateSystemClient() - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getParams() - Method in class com.lucidworks.cloud.api.call.impl.SolrPayloadRequest

getPartitions(boolean) - Method in class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

getPartitions(boolean) - Method in interface com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy

Returns a list of Solr collection names where documents have been assigned by this strategy.

getPartitionsForQuery(MultivaluedMap<String, String>) - Method in class com.lucidworks.apollo.partitioning.DefaultDocumentAssignmentStrategy

getPartitionsForQuery(MultivaluedMap<String, String>) - Method in interface com.lucidworks.apollo.partitioning.DocumentAssignmentStrategy

Returns a list of Solr collection names that need to be queried to satisfy the query criteria.

getPassword() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

getPath(String) - Method in class com.lucidworks.apollo.component.CollectionStore

getPipeline(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

getPipeline(String) - Method in interface com.lucidworks.apollo.pipeline.BasePipelineComponent

getPipeline(String) - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

getPipeline(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager

Return the current pipeline instance for the given id, if it exists

getPipelineDefinitionRegistry() - Method in interface com.lucidworks.apollo.pipeline.BasePipelineComponent

getPipelineDefinitionRegistry() - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

getPipelineId() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getPipelineManager() - Method in interface com.lucidworks.apollo.pipeline.BasePipelineComponent

getPipelineManager() - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

getPipelineOrFail(String) - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

getPipelineStagesForStats(Pipeline<PipelineDocument>, FieldMappingConfig) - Static method in class com.lucidworks.apollo.pipeline.index.InternalPipelineStatsUtils

getProperties() - Method in class com.lucidworks.apollo.pipeline.PipelineStateTransition

Deprecated.

getProperty(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getProperty(String, String) - Method in class com.lucidworks.apollo.pipeline.AbstractStage

getProperty(String, String) - Method in interface com.lucidworks.apollo.pipeline.Configurable

getProperty(String, String) - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getQueryParams() - Method in class com.lucidworks.js.api.client.CallSpec

getRecentErrors() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getRedactingProcessor() - Method in class com.lucidworks.apollo.rest.providers.DefaultMessageBodyRedactor

getReplicaListTransformer(SolrParams, String, String, String, NodesSysProps) - Method in class com.lucidworks.cloud.api.solr.FusionReplicaListTransformerGenerator

getRequestType() - Method in class com.lucidworks.cloud.api.call.impl.SolrPayloadRequest

getResourceClient(Class<T>) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getResourceClient(Class<T>, Object) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getResourceClient(Class<T>, MultivaluedMap<String, String>) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getResourceClient(String) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getResourceClient(String, MultivaluedMap<String, String>) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getResourceClientWithQueryParams(Class<T>, MultivaluedMap<String, String>) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getRunningTimeMs() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getSchemes() - Method in interface com.lucidworks.cloud.api.call.CallBuilder

getSchemes() - Method in class com.lucidworks.cloud.api.call.impl.HttpCallBuilder

getSchemes() - Method in class com.lucidworks.cloud.api.call.impl.ServiceCallBuilder

getSchemes() - Method in class com.lucidworks.cloud.api.call.impl.SolrCallBuilder

getSearchCluster(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getSearchLogDocIdFieldName(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSearchLogDocIdLimit(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSearchLogsCollectionName(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getServiceHistory(String, String, int) - Method in class com.lucidworks.apollo.common.models.HistoryStore

getSessionTimeoutMs() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

Timeout in milliseconds Curator will attempt to set for the ZooKeeper session.

getSize(Collection<T>, Class<?>, Type, Annotation[], MediaType) - Method in class com.lucidworks.apollo.rest.providers.RedactingCollectionMessageBodyWriter

getSize(T, Class<?>, Type, Annotation[], MediaType) - Method in class com.lucidworks.apollo.rest.providers.RedactingMessageBodyWriter

getSolrBufferConcurrency() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSolrBufferFlushInterval() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSolrBufferSize() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSolrClient() - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent.OverrideCollectionSolrClient

getSolrClient(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

getSolrCommitWithin() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSolrServer(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

Deprecated.

getSolrSignalAggrCollection(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

Return the name of the aggregated signals collection.

getSolrSignalCollection(String) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

Return the name of the raw signals collection.

getSolrZKClientTimeout() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getSolrZkConnectTimeout() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

getStageConfig() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

getStages() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getStageType() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

getStageType() - Method in interface com.lucidworks.apollo.pipeline.Stage

getStageTypes() - Method in interface com.lucidworks.apollo.pipeline.StageFactory

getStartTime() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getStartupConnectMs() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

Timeout in milliseconds API will wait for curator connection during startup

getState() - Method in class com.lucidworks.apollo.pipeline.Pipeline

getState() - Method in class com.lucidworks.apollo.pipeline.PipelineStateTransition

Deprecated.

getThreadPoolName() - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

getTotalCollectionCount() - Method in class com.lucidworks.apollo.component.CollectionComponent

This returns the number of collections *that are registered in Apollo.*.

getType() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage.StageExecutionInfo

getUpdateModifier(String, PipelineDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

getUri() - Method in class com.lucidworks.js.api.client.CallSpec

getUsername() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

getValidationQueryTimeout() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

getValue() - Method in class com.lucidworks.apollo.util.ValueHolder

getVersion() - Method in class com.lucidworks.cloud.api.solr.parser.JsonPathResponseParser

getWithRetries(Class<T>, Object) - Method in class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

getWrappedScript(String, String, ObjectMapper) - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

Takes in the wrapper template and the script and returns the converted script

getWrappedScript(String, String, ObjectMapper) - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

Takes in the wrapper template and the script and returns the converted script

getWriterType() - Method in class com.lucidworks.cloud.api.solr.parser.JsonPathResponseParser

getZkConnect() - Method in class com.lucidworks.apollo.config.CuratorConfiguration

GRAALVM_ENGINE - Static variable in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

GraalVMContextFactory - Interface in com.lucidworks.apollo.util

Factory interface for creating GraalVM JavaScript contexts with different security configurations.

GraalVmScriptEngineFactory - Class in com.lucidworks.apollo.util

GROUP_NAME - Static variable in class com.lucidworks.apollo.component.SystemAppRegistrar

H

handleSignal(String, String, Context) - Method in class com.lucidworks.apollo.pipeline.AbstractStage

handleSignal(String, String, Context) - Method in interface com.lucidworks.apollo.pipeline.Processor

Handle a signal

handleSignal(String, String, Context) - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

hasCollection(String) - Method in class com.lucidworks.apollo.component.CollectionComponent

hashCode() - Method in class com.lucidworks.apollo.common.models.HistoryEvent

hashCode() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

hasSideEffects() - Method in interface com.lucidworks.apollo.pipeline.WithSideEffects

head(Node, int) - Method in class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom.W3CBuilder

HistoryEvent - Class in com.lucidworks.apollo.common.models

HistoryEvent(Date, Date, String, String, String, Map<String, Object>) - Constructor for class com.lucidworks.apollo.common.models.HistoryEvent

HistoryEvent(Date, Date, String, String, String, Map<String, Object>, RESTError) - Constructor for class com.lucidworks.apollo.common.models.HistoryEvent

HistoryEvent.TruncatingRESTErrorSerializer - Class in com.lucidworks.apollo.common.models

Overrides the default RESTError serialization logic to limit the stack trace verbosity; has to be public static to be instantiated by JSON framework.

historyKeyPrefix - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

HistoryStore - Class in com.lucidworks.apollo.common.models

HistoryStore() - Constructor for class com.lucidworks.apollo.common.models.HistoryStore

HOST_ACCESS - Static variable in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

HttpCall - Class in com.lucidworks.cloud.api.call.impl

HttpCall(RestTemplate, CallParams, AuthzSupport) - Constructor for class com.lucidworks.cloud.api.call.impl.HttpCall

httpCallBuilder(RestTemplateCustomizer, Duration, AuthzSupport) - Method in class com.lucidworks.cloud.api.call.CallApiConfiguration

HttpCallBuilder - Class in com.lucidworks.cloud.api.call.impl

Builder for HttpCall.

HttpCallBuilder(RestTemplateCustomizer, Duration, AuthzSupport) - Constructor for class com.lucidworks.cloud.api.call.impl.HttpCallBuilder

I

INDEX_ANNOTATIONS - Static variable in class com.lucidworks.apollo.component.PipelineDocumentUtils

indexObjectMapper() - Static method in class com.lucidworks.apollo.pipeline.events.FusionCrudEventConfiguration

init() - Method in class com.lucidworks.apollo.component.CollectionComponent

init() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

init() - Method in interface com.lucidworks.apollo.pipeline.Configurable

init() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

init() - Method in class com.lucidworks.apollo.util.ValueHolder

init() - Method in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

initManagedModeEnabled() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

instanceId - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus

InternalPipelineStatsUtils - Class in com.lucidworks.apollo.pipeline.index

InternalPipelineStatsUtils() - Constructor for class com.lucidworks.apollo.pipeline.index.InternalPipelineStatsUtils

invalidateCachedDocumentAssignmentStrategy(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

invalidateObject(T) - Method in class com.lucidworks.apollo.util.SingleValuePool

isAuthorized() - Method in interface com.lucidworks.cloud.api.call.Call

Check whether this call is permitted according to AuthzSupport

isAuthorized() - Method in class com.lucidworks.cloud.api.call.impl.HttpCall

isAuthorized() - Method in class com.lucidworks.cloud.api.call.impl.ServiceCall

isAuthorized() - Method in class com.lucidworks.cloud.api.call.impl.SolrCall

isAuthorized(HttpAccessRequest, AuthorizationContext) - Method in class com.lucidworks.cloud.api.security.AuthzSupport

isCommandsDocument(PipelineDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

Return true if the given pipeline document is a special "Commands" document.

isCompilable() - Static method in class com.lucidworks.apollo.util.ScriptEngineFactory

Do instances returned by this factory implement Compilable?

isDataModelDocument(PipelineDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

Checks if the given PipelineDocument is a data model document, i.e.

isInState(Pipeline.State...) - Method in class com.lucidworks.apollo.pipeline.Pipeline

isJavascriptIsolatedMode() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

Returns whether JavaScript isolated mode is enabled.

isManagedModeEnabled() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

isolatedPackageLookup(String...) - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

Creates a highly restrictive package lookup for isolated mode that blocks: - Network access (java.net, javax.ws, jakarta.ws, HTTP clients) - System access (System.getenv, Runtime, ProcessBuilder) - File I/O (java.io) - Reflection (java.lang.reflect) - Any potential K8s environment access This mode only allows safe basic types and pipeline-specific classes.

isTerminalState() - Method in class com.lucidworks.apollo.pipeline.Pipeline

isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class com.lucidworks.apollo.rest.providers.RedactingCollectionMessageBodyWriter

isWriteable(Class<?>, Type, Annotation[], MediaType) - Method in class com.lucidworks.apollo.rest.providers.RedactingMessageBodyWriter

Test if the entity is a RedactingMessageBodyWriter.clazz or a Collection of RedactingMessageBodyWriter.clazz

J

JAVASCRIPT_ISOLATED_MODE - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

JsonPathResponseParser - Class in com.lucidworks.cloud.api.solr.parser

Extracts from response only requested paths and add them to returned map in a flat manner.

JsonPathResponseParser(String...) - Constructor for class com.lucidworks.cloud.api.solr.parser.JsonPathResponseParser

JsoupToW3CDom - Class in com.lucidworks.apollo.pipeline.util

Helper class to transform a Document to a org.w3c.dom.Document, for integration with toolsets that use the W3C DOM.

JsoupToW3CDom() - Constructor for class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom

JsoupToW3CDom.W3CBuilder - Class in com.lucidworks.apollo.pipeline.util

Implements the conversion by walking the input.

L

Lifecycle - Interface in com.lucidworks.apollo.pipeline

Something that can be started and stopped

LinkExtractor - Interface in com.lucidworks.apollo.links

Traverse an object and extract Links

list() - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

list() - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

listAllItems(String) - Method in class com.lucidworks.apollo.common.models.HistoryStore

listAllItems(String, String) - Method in class com.lucidworks.apollo.common.models.HistoryStore

listAllServices() - Method in class com.lucidworks.apollo.common.models.HistoryStore

listAllServices(String) - Method in class com.lucidworks.apollo.common.models.HistoryStore

listCollections() - Method in class com.lucidworks.apollo.component.CollectionComponent

ListeningExecutorServiceBuilder() - Constructor for class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

load(String) - Method in class com.lucidworks.apollo.pipeline.events.AbstractCachingClient

loadConfigsFromResource(String, Class<T>, ClassLoader) - Method in class com.lucidworks.apollo.config.ConfigResourceLoaderFactory

log - Static variable in class com.lucidworks.cloud.api.solr.PipelineCloudSolrClient

log - Static variable in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

LW_DATA_MODEL_TYPE_S - Static variable in class com.lucidworks.apollo.component.PipelineDocumentUtils

M

MANAGED_MODE_BYPASS - Static variable in class com.lucidworks.apollo.pipeline.FusionMetricConstants

metric collected when processing is bypassed due to managed mode enabled

MANAGED_MODE_KEY - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

ManagedJavascriptSupplier - Interface in com.lucidworks.apollo.pipeline.util

Created to provide alternative sources of Javascript than a typical Javascript stage.

managedModeEnabled() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

managedModeEnabled() - Method in class com.lucidworks.apollo.pipeline.AbstractStage

managedModeEnabled() - Method in interface com.lucidworks.apollo.pipeline.BasePipelineComponent

managedModeEnabled() - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

managedModeEnabled() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

managedModeEnabled() - Method in interface com.lucidworks.apollo.pipeline.Stage

mapToPipelineDocument(Map<String, Object>) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

maxBufferSize - Variable in class com.lucidworks.apollo.component.BufferingSolrServer

maxFlushInterval - Variable in class com.lucidworks.apollo.component.BufferingSolrServer

maybeStop() - Method in class com.lucidworks.apollo.pipeline.Pipeline

message - Variable in class com.lucidworks.apollo.pipeline.RuntimeStage.ThrowableAndMessage

MESSAGE - Static variable in class com.lucidworks.apollo.common.models.HistoryEvent

MessageBodyRedactor<T> - Interface in com.lucidworks.apollo.rest.providers

METRICS_INDEXING_ENABLED - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

metricsIndexingEnabled() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

metricsKeyPrefix - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

N

newBuilder() - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

newByteChannel(Path, Set<? extends OpenOption>, FileAttribute<?>...) - Method in class com.lucidworks.apollo.util.BlobFileSystem

newCachedThreadPool(String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

Creates a thread pool that creates new threads as needed, but will reuse previously constructed threads when they are available.

newCachedThreadPool(String) - Method in interface com.lucidworks.apollo.component.ExecutorComponent

newDirectoryStream(Path, DirectoryStream.Filter<? super Path>) - Method in class com.lucidworks.apollo.util.BlobFileSystem

newFixedThreadPool(int, String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

Creates a thread pool that reuses a fixed number of threads operating off a shared unbounded queue, using the provided ThreadFactory to create new threads when needed.

newFixedThreadPool(int, String) - Method in interface com.lucidworks.apollo.component.ExecutorComponent

newPipeline(String, String, List<StageConfig>, StageFactory<M>, MetricRegistry, Map<String, String>) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager

Delegate the actual construction of a Pipeline instance to a subclass, so we can get subtypes of Pipeline

newSingleThreadExecutor(String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent

newSingleThreadExecutor(String) - Method in interface com.lucidworks.apollo.component.ExecutorComponent

newStageCallback() - Method in class com.lucidworks.apollo.pipeline.Pipeline

Method for generating a new default StageCallback for this pipeline.

NotReallyCompiledScript - Class in com.lucidworks.apollo.util

Deprecated.

we have a control over the script engine, and we should not use not compilable engines I hope this class is not really used anywhere

NotReallyCompiledScript(String) - Constructor for class com.lucidworks.apollo.util.ScriptEngineFactory.NotReallyCompiledScript

NotReallyCompiledScript(String, String) - Constructor for class com.lucidworks.apollo.util.NotReallyCompiledScript

Deprecated.

NOW_KEY - Static variable in class com.lucidworks.apollo.pipeline.AbstractStage

O

objectMapperJaxRsProvider() - Method in class com.lucidworks.cloud.api.call.CallApiConfiguration

objectToInputStream(Object) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

objectToJsonDOM(Object, ObjectMapper, JsonXMLConfig) - Static method in class com.lucidworks.apollo.pipeline.util.RPCUtils

ok() - Method in interface com.lucidworks.apollo.resources.SolrProxyResource

onCollectionAdded(String) - Method in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

onCollectionAdded(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

onCollectionRemoved(String) - Method in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

onCollectionRemoved(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

onCollectionUpdated(String) - Method in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware

onCollectionUpdated(String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

onFinished(Runnable) - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator

onFinished(Runnable) - Method in interface com.lucidworks.apollo.pipeline.Generator

onItemAdded(String, ItemReadStore.ItemAndVersion<Collection>) - Method in class com.lucidworks.apollo.component.CollectionComponent

onItemRemoved(String, ItemReadStore.ItemAndVersion<Collection>) - Method in class com.lucidworks.apollo.component.CollectionComponent

onItemUpdated(String, ItemReadStore.ItemAndVersion<Collection>) - Method in class com.lucidworks.apollo.component.CollectionComponent

OPENJDK_NASHORN_ENGINE - Static variable in class com.lucidworks.apollo.util.ScriptEngineFactory

OverrideCollectionSolrClient(CloudSolrClient, String) - Constructor for class com.lucidworks.cloud.api.solr.SolrClusterComponent.OverrideCollectionSolrClient

P

packageLookup(String...) - Static method in class com.lucidworks.apollo.util.GraalVmScriptEngineFactory

paramsInited - Variable in class com.lucidworks.apollo.pipeline.AbstractStage

parsePath(String) - Method in class com.lucidworks.apollo.util.BlobFileSystem

parsePath(URI) - Method in class com.lucidworks.apollo.util.BlobFileSystem

passivateObject(PooledObject<ValueHolder<Object>>) - Method in class com.lucidworks.apollo.util.CompiledScriptPoolFactory

PATH - Static variable in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

PATH - Static variable in interface com.lucidworks.apollo.resources.SolrProxyResource

PAUSED - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

PAUSING - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

Pipeline<M> - Class in com.lucidworks.apollo.pipeline

Main runtime support for a pipeline (the actual thing that runs) Controls wiring the stages together, starting, and stopping them.

Pipeline(String, String, List<StageConfig>, StageFactory<M>, MetricRegistry, MetricRegistry, ConfigurationComponent, Map<String, String>) - Constructor for class com.lucidworks.apollo.pipeline.Pipeline

PIPELINE_EXECUTION_DURATION_SECS - Static variable in class com.lucidworks.apollo.pipeline.Pipeline

Pipeline.State - Enum Class in com.lucidworks.apollo.pipeline

PipelineCloudSolrClient - Class in com.lucidworks.cloud.api.solr

Create a new client object that connects to Zookeeper and is always aware of the SolrCloud state.

PipelineCloudSolrClient(SearchCluster) - Constructor for class com.lucidworks.cloud.api.solr.PipelineCloudSolrClient

PipelineCloudSolrClient(ZkClientClusterStateProvider) - Constructor for class com.lucidworks.cloud.api.solr.PipelineCloudSolrClient

PipelineDefinitionMergeUtil - Class in com.lucidworks.apollo.pipeline

PipelineDefinitionMergeUtil() - Constructor for class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

PipelineDefinitionRegistry<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> - Interface in com.lucidworks.apollo.pipeline

PipelineDocumentUtils - Class in com.lucidworks.apollo.component

PipelineDocumentUtils() - Constructor for class com.lucidworks.apollo.component.PipelineDocumentUtils

pipelineId - Variable in class com.lucidworks.apollo.pipeline.Pipeline

pipelineId - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus

PipelineManager<M> - Interface in com.lucidworks.apollo.pipeline

PipelineRuntimeException - Exception in com.lucidworks.apollo.pipeline

PipelineRuntimeException(String) - Constructor for exception com.lucidworks.apollo.pipeline.PipelineRuntimeException

PipelineRuntimeException(String, Throwable) - Constructor for exception com.lucidworks.apollo.pipeline.PipelineRuntimeException

PipelineRuntimeException(Throwable) - Constructor for exception com.lucidworks.apollo.pipeline.PipelineRuntimeException

PipelineStateTransition - Class in com.lucidworks.apollo.pipeline

Deprecated.

is it used anywhere?

PipelineStateTransition(PipelineStateTransition.State, Map<String, String>) - Constructor for class com.lucidworks.apollo.pipeline.PipelineStateTransition

Deprecated.

PipelineStateTransition.State - Enum Class in com.lucidworks.apollo.pipeline

Deprecated.

PipelineStatus - Class in com.lucidworks.apollo.pipeline

Represents a snapshot of the Pipeline's state.

prefixPipelineDocumentFields(PipelineDocument, String) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

put the prefix infront of every field within the pipeline doc

preInit(StageAssistFactoryParams) - Method in class com.lucidworks.apollo.pipeline.AbstractStage

preInit(StageAssistFactoryParams) - Method in interface com.lucidworks.apollo.pipeline.Stage

process(M, Context, StageOutput<M>) - Method in class com.lucidworks.apollo.pipeline.AbstractStage

Implements the default behavior for a stage when it receives a message (which is to simply pass it to the next stage)

process(M, Context, StageOutput<M>) - Method in interface com.lucidworks.apollo.pipeline.Processor

Process a passed in message

process(M, Context, StageOutput<M>) - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

Determine if the current stage should run, and if so run it

Processor<M> - Interface in com.lucidworks.apollo.pipeline

Something that can accept and process a message

processResponse(InputStream, String) - Method in class com.lucidworks.cloud.api.solr.parser.JsonPathResponseParser

processResponse(Reader) - Method in class com.lucidworks.cloud.api.solr.parser.JsonPathResponseParser

processXMLRule(TransformerFactory, NodeList, Map<String, Object>, String) - Static method in class com.lucidworks.apollo.pipeline.util.RPCUtils

proxyDeleteRequestToSolr(String, String, HttpHeaders, UriInfo) - Method in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

proxyDeleteRequestToSolr(String, String, HttpHeaders, UriInfo, InputStream) - Method in interface com.lucidworks.apollo.resources.SolrProxyResource

proxyGetRequestToSolr(String, String, HttpHeaders, UriInfo) - Method in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

proxyHeadRequestToSolr(String, String, HttpHeaders, UriInfo) - Method in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

proxyOptionsRequestToSolr(String, String, HttpHeaders, UriInfo) - Method in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

proxyPostRequestToSolr(String, String, HttpHeaders, UriInfo, AuthorizationContext, InputStream) - Method in interface com.lucidworks.apollo.resources.SolrProxyResource

proxyPostRequestToSolr(String, String, HttpHeaders, UriInfo, InputStream) - Method in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

proxyPutRequestToSolr(String, String, HttpHeaders, UriInfo, InputStream) - Method in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

proxyPutRequestToSolr(String, String, HttpHeaders, UriInfo, InputStream) - Method in interface com.lucidworks.apollo.resources.SolrProxyResource

proxyRequestToSolr(String, String, HttpHeaders, UriInfo, AuthorizationContext, InputStream) - Method in interface com.lucidworks.apollo.resources.SolrProxyResource

PUBLIC_INDEX_PIPELINES - Static variable in class com.lucidworks.apollo.component.SystemAppRegistrar

PUBLIC_QUERY_PIPELINES - Static variable in class com.lucidworks.apollo.component.SystemAppRegistrar

R

read(byte[]) - Method in class com.lucidworks.apollo.store.DecryptingPipelineReader

readAttributes(Path, String, LinkOption...) - Method in class com.lucidworks.apollo.util.BlobFileSystem

READY - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

redactEntity(T) - Method in class com.lucidworks.apollo.rest.providers.DefaultMessageBodyRedactor

redactEntity(T) - Method in interface com.lucidworks.apollo.rest.providers.MessageBodyRedactor

RedactingCollectionMessageBodyWriter<T> - Class in com.lucidworks.apollo.rest.providers

RedactingCollectionMessageBodyWriter(MessageBodyRedactor<T>, Class<T>, ObjectMapper) - Constructor for class com.lucidworks.apollo.rest.providers.RedactingCollectionMessageBodyWriter

RedactingMessageBodyWriter<T> - Class in com.lucidworks.apollo.rest.providers

Base implementation for a MessageBodyWriter that performs redaction of sensitive data

RedactingMessageBodyWriter(MessageBodyRedactor<T>, Class<T>, ObjectMapper) - Constructor for class com.lucidworks.apollo.rest.providers.RedactingMessageBodyWriter

RedactingSearchClusterMessageBodyWriter - Class in com.lucidworks.apollo.rest.providers

RedactingSearchClusterMessageBodyWriter(DefaultMessageBodyRedactor.SearchClusterMessageBodyRedactor, ObjectMapper) - Constructor for class com.lucidworks.apollo.rest.providers.RedactingSearchClusterMessageBodyWriter

refreshPipeline(String) - Method in interface com.lucidworks.apollo.pipeline.BasePipelineComponent

refreshPipeline(String) - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

register(T) - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

register(T) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

registerCallBuilder(String, CallBuilder) - Method in class com.lucidworks.cloud.api.call.CallFactory

rejectedExecution(Runnable, ThreadPoolExecutor) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.AbortPolicy

Always throws RejectedExecutionException.

request(SolrRequest, String) - Method in class com.lucidworks.apollo.component.BufferingSolrServer

request(SolrRequest, String) - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent.OverrideCollectionSolrClient

REQUEST - Static variable in class com.lucidworks.apollo.pipeline.util.RPCUtils

RESPONSE - Static variable in class com.lucidworks.apollo.pipeline.util.RPCUtils

responseToListOfPojo(Response, Class<T>, ObjectMapper) - Static method in class com.lucidworks.apollo.rest.Util

responseToPojo(Response, Class<T>, ObjectMapper) - Static method in class com.lucidworks.apollo.rest.Util

responseToRESTError(Response, ObjectMapper) - Static method in class com.lucidworks.apollo.rest.Util

RESULTS_LOCATION - Static variable in class com.lucidworks.apollo.pipeline.util.RPCUtils

returnObject(T) - Method in class com.lucidworks.apollo.util.SingleValuePool

RowConversionHelper - Class in com.lucidworks.apollo.pipeline.helper

RowConversionHelper(String) - Constructor for class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

RowConversionHelper(String, boolean) - Constructor for class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

ROWS_RETRIEVED_KEY - Static variable in class com.lucidworks.apollo.blob.sql.SQLHelper

RPCUtils - Class in com.lucidworks.apollo.pipeline.util

Common code between IndexingRPCStage and RPCQueryStage

RUNNING - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

RUNNING - Enum constant in enum class com.lucidworks.apollo.pipeline.PipelineStateTransition.State

Deprecated.

runningTimeMs - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus

RuntimeStage<M> - Class in com.lucidworks.apollo.pipeline

Decorates a Stage instance with some telemetry and bounds checking

RuntimeStage(String, Stage<M, C>, C, Optional<RuntimeStage<M>>, MetricRegistry) - Constructor for class com.lucidworks.apollo.pipeline.RuntimeStage

RuntimeStage.StageException - Exception in com.lucidworks.apollo.pipeline

RuntimeStage.StageExecutionInfo - Class in com.lucidworks.apollo.pipeline

RuntimeStage.ThrowableAndMessage<M> - Class in com.lucidworks.apollo.pipeline

S

SchemaLinkExtractor - Class in com.lucidworks.apollo.links

Extract links by using a SchemaProcessor.

SchemaLinkExtractor() - Constructor for class com.lucidworks.apollo.links.SchemaLinkExtractor

SchemaLinkExtractor(String) - Constructor for class com.lucidworks.apollo.links.SchemaLinkExtractor

SchemaLinkExtractor(String, SchemaProcessorFactory) - Constructor for class com.lucidworks.apollo.links.SchemaLinkExtractor

ScriptEngineFactory - Class in com.lucidworks.apollo.util

Simple static "factory" for Javascript ScriptEngine instances

ScriptEngineFactory() - Constructor for class com.lucidworks.apollo.util.ScriptEngineFactory

ScriptEngineFactory.NotReallyCompiledScript - Class in com.lucidworks.apollo.util

SearchClusterMessageBodyRedactor() - Constructor for class com.lucidworks.apollo.rest.providers.DefaultMessageBodyRedactor.SearchClusterMessageBodyRedactor

SearchClusterStore - Class in com.lucidworks.apollo.component

Stores records about search clusters -- i.e.

SearchClusterStore(CuratorFramework, MetricRegistry, ObjectMapper, StringEncryptor, StringDecryptor) - Constructor for class com.lucidworks.apollo.component.SearchClusterStore

SearchClusterStore.Cache - Class in com.lucidworks.apollo.component

send(Iterator<M>, Context) - Method in class com.lucidworks.apollo.pipeline.Pipeline

send(M, Context) - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator

send(M, Context) - Method in class com.lucidworks.apollo.pipeline.Pipeline

send(M, Context) - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

Send a message to the next stage in the pipeline, if set

send(M, Context) - Method in interface com.lucidworks.apollo.pipeline.StageOutput

sendEndOfBatch(Context) - Method in class com.lucidworks.apollo.pipeline.Pipeline

for use when messages are being sent through the non iterators method when a downstream consumer needs to know that the last pipeline message has been sent

serialize(RESTError, JsonGenerator, SerializerProvider) - Method in class com.lucidworks.apollo.common.models.HistoryEvent.TruncatingRESTErrorSerializer

serializeWithType(RESTError, JsonGenerator, SerializerProvider, TypeSerializer) - Method in class com.lucidworks.apollo.common.models.HistoryEvent.TruncatingRESTErrorSerializer

SERVICE_NAME - Static variable in interface com.lucidworks.apollo.resources.SolrAdminProxyResource

SERVICE_NAME - Static variable in interface com.lucidworks.apollo.resources.SolrProxyResource

ServiceCall - Class in com.lucidworks.cloud.api.call.impl

ServiceCall(RestTemplate, CallParams, String, ObjectMapper) - Constructor for class com.lucidworks.cloud.api.call.impl.ServiceCall

serviceCallBuilder(ContextResolver<ObjectMapper>, String, RestTemplate) - Method in class com.lucidworks.cloud.api.call.CallApiConfiguration

ServiceCallBuilder - Class in com.lucidworks.cloud.api.call.impl

ServiceCallBuilder(ContextResolver<ObjectMapper>, String, RestTemplate) - Constructor for class com.lucidworks.cloud.api.call.impl.ServiceCallBuilder

setBaseSleepMs(int) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setConnectTimeoutMs(int) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setCorePoolSize(int) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

setEntity(Object) - Method in class com.lucidworks.js.api.client.CallSpec

setFetchSize(Statement, int) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

setHandler(RejectedExecutionHandler) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

setHeaders(Map<String, String>) - Method in class com.lucidworks.js.api.client.CallSpec

setKeepAliveTime(long, TimeUnit) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

The amount of time

setManagedModeEnabled(boolean) - Method in class com.lucidworks.apollo.config.ConfigurationComponent

setMaximumPoolSize(int) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

The ExecutorService will always prefer adding tasks to the queue over adding threads beyond the core pool size.

setMaxRetries(int) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setMaxSleepMs(int) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setMethod(String) - Method in class com.lucidworks.js.api.client.CallSpec

setNamespace(String) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setQueryParams(Map<String, String>) - Method in class com.lucidworks.js.api.client.CallSpec

setRows(Statement, int) - Method in class com.lucidworks.apollo.blob.sql.SQLHelper

setSessionTimeoutMs(int) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setStageOutput(StageOutput<M>) - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator

setStartupConnectMs(int) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

setTargetInstanceHost(String) - Method in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

setTargetInstancePort(String) - Method in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

setThreadNameFormat(String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

setThreadPoolName(String) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

Set the name of this thread pool.

setUri(String) - Method in class com.lucidworks.js.api.client.CallSpec

setWithMetrics(boolean) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

setWorkQueue(BlockingQueue<Runnable>) - Method in class com.lucidworks.apollo.component.DefaultExecutorComponent.ListeningExecutorServiceBuilder

This will almost always be a SynchronousQueue or an ArrayBlockingQueue with a reasonable maximum size.

setZkConnect(String) - Method in class com.lucidworks.apollo.config.CuratorConfiguration

SHARDS_PARAM - Static variable in class com.lucidworks.cloud.api.solr.SolrAuthorizationComponent

shutdown() - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

shutdown() - Method in class com.lucidworks.cloud.api.solr.SolrClusterComponent

SIGNAL_COUNTER - Static variable in class com.lucidworks.apollo.pipeline.RuntimeStage

SingleValuePool<T> - Class in com.lucidworks.apollo.util

A pool that holds a single value and return it on borrowObject.

SingleValuePool(T) - Constructor for class com.lucidworks.apollo.util.SingleValuePool

SOLR_BUFFER_CONCURRENCY - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_BUFFER_FLUSH_INTERVAL - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_BUFFER_SIZE - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_COMMIT_WITHIN - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_ZK_CLIENT_TIMEOUT - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_ZK_CONNECT - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_ZK_CONNECT_KEY - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SOLR_ZK_CONNECT_TIMEOUT - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

SolrAdminProxyResource - Interface in com.lucidworks.apollo.resources

solrAuthorizationComponent(CollectionComponent) - Method in class com.lucidworks.cloud.api.solr.SolrPipelineClientConfiguration

SolrAuthorizationComponent - Class in com.lucidworks.cloud.api.solr

Solr users can do federated search using "collection" or "shards" query params, thus bypassing our security enforcements.

SolrAuthorizationComponent(CollectionComponent) - Constructor for class com.lucidworks.cloud.api.solr.SolrAuthorizationComponent

SolrCall - Class in com.lucidworks.cloud.api.call.impl

SolrCall(SolrClient, SolrRequest, String, AuthzSupport) - Constructor for class com.lucidworks.cloud.api.call.impl.SolrCall

solrCallBuilder(SolrClusterComponent, AuthzSupport) - Method in class com.lucidworks.cloud.api.call.CallApiConfiguration

SolrCallBuilder - Class in com.lucidworks.cloud.api.call.impl

SolrCallBuilder(SolrClusterComponent, AuthzSupport) - Constructor for class com.lucidworks.cloud.api.call.impl.SolrCallBuilder

solrClusterComponent(SolrClusterDiscoveryClient, CollectionStore, CollectionComponent, ConfigurationComponent, CuratorFramework) - Method in class com.lucidworks.cloud.api.solr.SolrPipelineClientConfiguration

SolrClusterComponent - Class in com.lucidworks.cloud.api.solr

Provides access to the Solr servers associated with a given collectionId.

SolrClusterComponent(SolrClusterDiscoveryClient, CollectionStore, CollectionComponent, ConfigurationComponent, CuratorFramework) - Constructor for class com.lucidworks.cloud.api.solr.SolrClusterComponent

SolrClusterComponent.OverrideCollectionSolrClient - Class in com.lucidworks.cloud.api.solr

Class to remember the requested collection.

solrClusterDiscoveryClient(CuratorFramework, ObjectMapper, StringDecryptor, SchemaProcessorFactory) - Method in class com.lucidworks.cloud.api.solr.SolrPipelineClientConfiguration

SolrClusterDiscoveryClient - Interface in com.lucidworks.cloud.api.solr

Discovery client for Search Solr clusters.

SolrClusterDiscoveryClientImpl - Class in com.lucidworks.cloud.api.solr

Discovery client for Search Solr clusters.

SolrClusterDiscoveryClientImpl(CuratorFramework, ObjectMapper, StringDecryptor, SchemaProcessorFactory) - Constructor for class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

SolrMetricsCollector - Interface in com.lucidworks.cloud.api.solr

Interface which is implemented by different classes which will be used to capture the solr metrics.

SolrMetricsFactory - Class in com.lucidworks.cloud.api.solr

Factory for native solr client to create a metrics collector based on type of request

SolrPayloadRequest - Class in com.lucidworks.cloud.api.call.impl

SolrPayloadRequest() - Constructor for class com.lucidworks.cloud.api.call.impl.SolrPayloadRequest

SolrPipelineClientConfiguration - Class in com.lucidworks.cloud.api.solr

SolrPipelineClientConfiguration() - Constructor for class com.lucidworks.cloud.api.solr.SolrPipelineClientConfiguration

SolrProxyResource - Interface in com.lucidworks.apollo.resources

SolrQueryMetrics - Class in com.lucidworks.cloud.api.solr

Stores metric information accumulated during processing of a Solr query.

SolrQueryMetrics(String, String, String) - Constructor for class com.lucidworks.cloud.api.solr.SolrQueryMetrics

source - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

split(String) - Static method in class com.lucidworks.apollo.config.ConfigurationComponent

splitParamValue(String) - Static method in class com.lucidworks.cloud.api.solr.SolrAuthorizationComponent

SQLHelper - Class in com.lucidworks.apollo.blob.sql

Helper class for common SQL tasks like getting data sources, etc.

SQLHelper(DataSourceProvider) - Constructor for class com.lucidworks.apollo.blob.sql.SQLHelper

Stage<M,C extends com.lucidworks.apollo.pipeline.StageConfig> - Interface in com.lucidworks.apollo.pipeline

The basic unit of a pipeline, a stage

STAGE_DONE - Static variable in class com.lucidworks.apollo.pipeline.RuntimeStage

STAGE_ERRORS - Static variable in class com.lucidworks.apollo.pipeline.RuntimeStage

STAGE_EXECUTION_INFO - Static variable in class com.lucidworks.apollo.pipeline.RuntimeStage

STAGE_SKIPPED_COUNTER - Static variable in class com.lucidworks.apollo.pipeline.RuntimeStage

StageAssistFactory<M,T extends Stage<M,? extends com.lucidworks.apollo.pipeline.StageConfig>> - Interface in com.lucidworks.apollo.pipeline

Base factory interface for use with Guice assisted inject factories.

StageAssistFactoryParams - Class in com.lucidworks.apollo.pipeline

StageAssistFactoryParams(String, ContextFactory, MetricRegistry, StageConfig, ConfigurationComponent) - Constructor for class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

StageAssistFactoryParams(String, ContextFactory, MetricRegistry, StageConfig, ConfigurationComponent, Map<String, String>) - Constructor for class com.lucidworks.apollo.pipeline.StageAssistFactoryParams

StageException(ErrorInfo, Throwable) - Constructor for exception com.lucidworks.apollo.pipeline.RuntimeStage.StageException

StageException(String) - Constructor for exception com.lucidworks.apollo.pipeline.RuntimeStage.StageException

StageException(String, Throwable) - Constructor for exception com.lucidworks.apollo.pipeline.RuntimeStage.StageException

StageExecutionInfo(String, String, boolean) - Constructor for class com.lucidworks.apollo.pipeline.RuntimeStage.StageExecutionInfo

StageFactory<M> - Interface in com.lucidworks.apollo.pipeline

Used for constructing Stage instances The arguments here represent the set of dependencies provide by the pipelines framework.

StageMetrics - Class in com.lucidworks.apollo.pipeline

StageMetrics() - Constructor for class com.lucidworks.apollo.pipeline.StageMetrics

StageOutput<M> - Interface in com.lucidworks.apollo.pipeline

Something for stages to write messages to

stagesAsMap(T) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil

Index StageConfigs into a Map for easy lookup

StageSchemaValidatingUpdateStrategy<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> - Class in com.lucidworks.apollo.pipeline.component

Pipeline Stage validator.

StageSchemaValidatingUpdateStrategy(ObjectMapper, Set<String>, SchemaProcessorFactory) - Constructor for class com.lucidworks.apollo.pipeline.component.StageSchemaValidatingUpdateStrategy

start - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

start() - Method in interface com.lucidworks.apollo.pipeline.Lifecycle

start() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

STARTING - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

startTime - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus

startTime - Variable in class com.lucidworks.cloud.api.solr.SolrQueryMetrics

state - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus

status - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

STATUS_ERROR - Static variable in class com.lucidworks.apollo.common.models.HistoryEvent

STATUS_OK - Static variable in class com.lucidworks.apollo.common.models.HistoryEvent

STATUS_WARNING - Static variable in class com.lucidworks.apollo.common.models.HistoryEvent

stop() - Method in interface com.lucidworks.apollo.pipeline.Lifecycle

stop() - Method in class com.lucidworks.apollo.pipeline.Pipeline

stop() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage

stopAndFinalizePipelineJob(String) - Method in interface com.lucidworks.apollo.pipeline.BasePipelineComponent

stopAndFinalizePipelineJob(String) - Method in class com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent

STOPPED - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

STOPPED - Enum constant in enum class com.lucidworks.apollo.pipeline.PipelineStateTransition.State

Deprecated.

STOPPING - Enum constant in enum class com.lucidworks.apollo.pipeline.Pipeline.State

STORE_PATH - Static variable in class com.lucidworks.apollo.component.SearchClusterStore

STORE_PATH - Static variable in class com.lucidworks.cloud.api.solr.SolrClusterDiscoveryClientImpl

stripTrailingSlash(String) - Static method in class com.lucidworks.apollo.rest.Util

substitute(String, Aggregatable, boolean) - Static method in class com.lucidworks.apollo.pipeline.util.RPCUtils

summary() - Static method in class com.lucidworks.apollo.pipeline.StageMetrics

syncFlush() - Method in class com.lucidworks.apollo.component.BufferingSolrServer

SystemAppRegistrar - Class in com.lucidworks.apollo.component

SystemAppRegistrar() - Constructor for class com.lucidworks.apollo.component.SystemAppRegistrar

T

t - Variable in class com.lucidworks.apollo.pipeline.RuntimeStage.ThrowableAndMessage

tail(Node, int) - Method in class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom.W3CBuilder

ThrowableAndMessage(M, Throwable) - Constructor for class com.lucidworks.apollo.pipeline.RuntimeStage.ThrowableAndMessage

throwErrorIfAny() - Method in class com.lucidworks.apollo.util.ValueHolder

timingHistogram() - Static method in class com.lucidworks.apollo.pipeline.StageMetrics

toAbsolutePath(Path) - Method in class com.lucidworks.apollo.util.BlobFileSystem

toMap(PipelineDocument) - Static method in class com.lucidworks.apollo.component.PipelineDocumentUtils

toPreAnalyzedField(AnnotatedText, boolean) - Static method in class com.lucidworks.apollo.component.AnnotationIndexingUtils

Convert AnnotatedField to Solr's PreAnalyzedField JSON format.

toRealPath(Path, LinkOption...) - Method in class com.lucidworks.apollo.util.BlobFileSystem

toRow(Map<String, Object>) - Method in class com.lucidworks.apollo.pipeline.helper.RowConversionHelper

toString() - Method in enum class com.lucidworks.apollo.pipeline.PipelineStateTransition.State

Deprecated.

toString() - Method in class com.lucidworks.apollo.pipeline.PipelineStatus

toString() - Method in class com.lucidworks.apollo.sql.DataSourceDescriptor

toString() - Method in class com.lucidworks.cloud.api.call.CallFactory

transform(List<T>) - Method in class com.lucidworks.cloud.api.solr.FusionParamReplicaListTransformer

TRANSFORMER - Static variable in class com.lucidworks.apollo.pipeline.PipelineStatus

TruncatingRESTErrorSerializer() - Constructor for class com.lucidworks.apollo.common.models.HistoryEvent.TruncatingRESTErrorSerializer

type - Variable in class com.lucidworks.apollo.common.models.HistoryEvent

type() - Element in annotation interface com.lucidworks.apollo.pipeline.AutoDiscover

A type name to bind to the annotated class

U

UnimplementedClientFactory - Class in com.lucidworks.apollo.pipeline

Class throws exception in each methods just to inform customers that it was removed and he can use different client

UnimplementedClientFactory() - Constructor for class com.lucidworks.apollo.pipeline.UnimplementedClientFactory

unregister(String) - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

unregister(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

UNSAFE_PATTERN - Static variable in class com.lucidworks.apollo.component.PipelineDocumentUtils

update(String, T) - Method in class com.lucidworks.apollo.pipeline.impl.AbstractPipelineDefinitionStore

update(String, T) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry

USAGE_MONITOR - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

USAGE_MONITOR_TEST_MODE - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

usageMonitorEnabled() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

usageMonitorTestMode() - Method in class com.lucidworks.apollo.config.ConfigurationComponent

Util - Class in com.lucidworks.apollo.rest

Util() - Constructor for class com.lucidworks.apollo.rest.Util

V

validate(E) - Method in interface com.lucidworks.apollo.resources.validators.AbstractCrudEntityValidator

value - Variable in class com.lucidworks.apollo.util.ValueHolder

ValueHolder<T> - Class in com.lucidworks.apollo.util

ValueHolder() - Constructor for class com.lucidworks.apollo.util.ValueHolder

valueOf(String) - Static method in enum class com.lucidworks.apollo.component.BufferingSolrServer.Action

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class com.lucidworks.apollo.pipeline.Pipeline.State

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class com.lucidworks.apollo.pipeline.PipelineStateTransition.State

Deprecated.

Returns the enum constant of this class with the specified name.

values() - Static method in enum class com.lucidworks.apollo.component.BufferingSolrServer.Action

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class com.lucidworks.apollo.pipeline.Pipeline.State

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class com.lucidworks.apollo.pipeline.PipelineStateTransition.State

Deprecated.

Returns an array containing the constants of this enum class, in the order they are declared.

W

W3CBuilder(Document) - Constructor for class com.lucidworks.apollo.pipeline.util.JsoupToW3CDom.W3CBuilder

wasCommError(Throwable) - Method in class com.lucidworks.cloud.api.solr.PipelineCloudSolrClient

WithSideEffects - Interface in com.lucidworks.apollo.pipeline

Marker interface to indicate a Stage has side-effects

wrap(ValueHolder) - Method in class com.lucidworks.apollo.util.CompiledScriptPoolFactory

write(T) - Method in class com.lucidworks.apollo.store.EncryptingPipelineWriter

writeTo(Collection<T>, Class<?>, Type, Annotation[], MediaType, MultivaluedMap<String, Object>, OutputStream) - Method in class com.lucidworks.apollo.rest.providers.RedactingCollectionMessageBodyWriter

writeTo(T, Class<?>, Type, Annotation[], MediaType, MultivaluedMap<String, Object>, OutputStream) - Method in class com.lucidworks.apollo.rest.providers.RedactingMessageBodyWriter

Redact and serialize one or more entities of RedactingMessageBodyWriter.clazz

Z

zerothStage(M, Context) - Method in class com.lucidworks.apollo.pipeline.Pipeline

ZK_CONNECT_KEY - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

ZK_NAMESPACE_KEY - Static variable in class com.lucidworks.apollo.config.ConfigurationComponent

A B C D E F G H I J L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form