Skip navigation links
A B C D E F G H I J L M N O P Q R S T U V W Z 

A

AbortPolicy() - Constructor for class com.lucidworks.apollo.component.ExecutorComponent.AbortPolicy
Creates an AbortPolicy.
absent() - Static method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
AbstractDefaultPipelineRegistrar - Class in com.lucidworks.apollo.pipeline
DON'T EXTEND THIS DIRECTLY.
AbstractGenerator<M,C extends StageConfig> - Class in com.lucidworks.apollo.pipeline
 
AbstractIndexPipelineRegistrar - Class in com.lucidworks.apollo.pipeline.index
Extend this to create an index pipeline on startup
AbstractItemReadStore<T> - Class in com.lucidworks.apollo.component
An abstract class representing a thing that reads items from somewhere.
AbstractItemReadStore(MetricRegistry, String, ItemReader<T>) - Constructor for class com.lucidworks.apollo.component.AbstractItemReadStore
 
AbstractItemStore<T> - Class in com.lucidworks.apollo.component
TODO: document me.
AbstractItemStore(String, MetricRegistry, ItemReader<T>, ItemWriter<T>) - Constructor for class com.lucidworks.apollo.component.AbstractItemStore
 
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, ItemReadWriteStore<StageConfig>, StageFactory<M>, ObjectMapper, StringEncryptor) - Constructor for class com.lucidworks.apollo.pipeline.AbstractPipelineManager
 
AbstractProcessor<M,C extends StageConfig> - Class in com.lucidworks.apollo.pipeline
 
AbstractStage<M,C extends StageConfig> - Class in com.lucidworks.apollo.pipeline
 
ADD - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
add(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(String, Collection<SolrInputDocument>, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer
 
add(String, SolrInputDocument, int) - Method in class com.lucidworks.apollo.component.BufferingSolrServer
 
addAnnotation(Annotation) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
addAnnotations(Collection<Annotation>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
addCollectionChangeListener(CollectionComponent.CollectionChangeAware) - Method in class com.lucidworks.apollo.component.CollectionComponent
 
addCommand(String, Map<String, String>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addCommand(Command) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addCommands(List<Command>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addFeature(String, String) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
addFeatures(Map<String, String>) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
addField(String, Object) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
This will add a field to the document.
addField(String, Object, String...) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addField(String, Object, List<Annotation>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addField(PipelineField) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addField(String, Object) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
addFieldIfDifferent(String, Object, String...) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addFieldIfDifferent(String, Object, List<Annotation>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addFieldIfDifferent(PipelineField) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addFields(String, Collection<?>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addFields(Collection<PipelineField>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addFields(String, Collection<?>) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
addItemHistory(String, String, HistoryEvent) - Method in class com.lucidworks.apollo.component.HistoryStore
 
addListener(MetricRegistryListener) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
addMetadata(String, String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
addMetadata(String, String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
addParam(String, String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
addServiceHistory(String, HistoryEvent) - Method in class com.lucidworks.apollo.component.HistoryStore
 
addStateListener(Runnable, Pipeline.State...) - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
allowCoreThreadTimeOut(boolean) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
 
ALLOWED_VALUES - Static variable in class com.lucidworks.apollo.component.ZKImportExportComponent
 
Annotation - Class in com.lucidworks.apollo.common.pipeline
Implementation of an Annotation.
Annotation() - Constructor for class com.lucidworks.apollo.common.pipeline.Annotation
 
Annotation(String, long, long, Map<String, String>) - Constructor for class com.lucidworks.apollo.common.pipeline.Annotation
 
APOLLO_LOG - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
APOLLO_LOG_LEVEL - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
APP_VERSION - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
append(LogEvent) - Method in class com.lucidworks.apollo.component.SolrLoggingComponent.SolrAppender
 
apply() - Method in class com.lucidworks.apollo.component.AuditComponent
 
apply(boolean, String) - Method in class com.lucidworks.apollo.component.SolrLoggingComponent
 
asList() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
AssistedIndexStageFactory - Class in com.lucidworks.apollo.pipeline.index
 
AssistedIndexStageFactory(Map<String, StageAssistFactory<PipelineDocument, ? extends Stage<PipelineDocument, ? extends StageConfig>>>) - Constructor for class com.lucidworks.apollo.pipeline.index.AssistedIndexStageFactory
 
ASYNC - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
ASYNC_APPENDER_NAME - Static variable in class com.lucidworks.apollo.component.SolrLoggingComponent
 
AUDIT_HEADER - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
AUDIT_HEADER_INTERNAL - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
AUDIT_LOG - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
AUDIT_LOG_INTERNAL - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
AuditComponent - Class in com.lucidworks.apollo.component
 
AuditComponent(SolrClientFactory, CollectionComponent, CollectionManager, ConfigurationComponent, CuratorComponent, SearchClusterStore) - Constructor for class com.lucidworks.apollo.component.AuditComponent
 
auditKeyPrefix - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
auditLogEnabled() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
auditLogInternalEnabled() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
AUTHZ_CONTEXT - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
AutoDiscover - Annotation Type in com.lucidworks.apollo.pipeline
Something that is intended to be auto-discovered by classpath scanning.

B

BASE_PACKAGES_KEY - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
BlobStoreResourceLoader - Class in com.lucidworks.apollo.component
 
BlobStoreResourceLoader(ClientComponent) - Constructor for class com.lucidworks.apollo.component.BlobStoreResourceLoader
 
BufferingSolrServer - Class in com.lucidworks.apollo.component
Simple class that wraps 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
 
build() - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
Build the ThreadPoolExecutor using the given configuration.
BUILD_NUMBER - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
buildCompositeConfiguration(CuratorFramework, ConcurrentCompositeConfiguration, int) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
Create one or more Zookeeper-backed ConfigurationSources and insert them into the provided CompositeConfiguration at the given index.
buildMap() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 

C

call() - Method in class com.lucidworks.apollo.component.DefaultSearchClusterRegistrar.SearchClusterWatcher
 
cancelTask(String, boolean) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
 
CHARSET - Static variable in class com.lucidworks.apollo.component.AbstractItemReadStore
 
ClasspathResourceLoader - Class in com.lucidworks.apollo.component
 
ClasspathResourceLoader() - Constructor for class com.lucidworks.apollo.component.ClasspathResourceLoader
 
clear() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
clear() - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
clearAllItemHistory(String) - Method in class com.lucidworks.apollo.component.HistoryStore
 
clearAllServiceHistory() - Method in class com.lucidworks.apollo.component.HistoryStore
 
clearItemHistory(String, String) - Method in class com.lucidworks.apollo.component.HistoryStore
 
clearParams() - Method in class com.lucidworks.apollo.pipeline.query.Request
 
clearServiceHistory(String) - Method in class com.lucidworks.apollo.component.HistoryStore
 
clearSignal() - Method in interface com.lucidworks.apollo.pipeline.Context
 
ClientComponent - Class in com.lucidworks.apollo.component
 
ClientComponent(ConfigurationComponent, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.ClientComponent
 
close() - Method in class com.lucidworks.apollo.component.ExecutorComponent
 
close() - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
close() - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationSource
 
COLLECTION_NAME - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
COLLECTION_NAME - Static variable in class com.lucidworks.apollo.component.SolrLoggingComponent
 
COLLECTION_PROPERTY - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
CollectionComponent - Class in com.lucidworks.apollo.component
Does basic data reading involving collections.
CollectionComponent(CuratorComponent, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.CollectionComponent
 
CollectionComponent.CollectionChangeAware - Interface in com.lucidworks.apollo.component
 
CollectionManager - Class in com.lucidworks.apollo.component
 
CollectionManager(CollectionStore, SearchClusterComponent, FeatureStore, CallFactory, ConfigurationComponent, ClientComponent) - Constructor for class com.lucidworks.apollo.component.CollectionManager
 
CollectionMetricHelper - Class in com.lucidworks.apollo.component
Encapsulates various interesting statistics involving collections.
CollectionMetricHelper(SearchClusterComponent, CollectionComponent, ClientComponent) - Constructor for class com.lucidworks.apollo.component.CollectionMetricHelper
 
CollectionMetricHelper.RequestsAndTime - Class in com.lucidworks.apollo.component
 
CollectionStore - Class in com.lucidworks.apollo.component
Store collection metadata in ZooKeeper
CollectionStore(CuratorComponent, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.CollectionStore
 
com.lucidworks.apollo.common.pipeline - package com.lucidworks.apollo.common.pipeline
 
com.lucidworks.apollo.component - package com.lucidworks.apollo.component
 
com.lucidworks.apollo.pipeline - package com.lucidworks.apollo.pipeline
 
com.lucidworks.apollo.pipeline.index - package com.lucidworks.apollo.pipeline.index
 
com.lucidworks.apollo.pipeline.query - package com.lucidworks.apollo.pipeline.query
 
Command - Class in com.lucidworks.apollo.common.pipeline
 
Command(String, Map<String, String>) - Constructor for class com.lucidworks.apollo.common.pipeline.Command
 
COMMAND_ADD - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
COMMAND_COMMIT - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
COMMAND_DELETE - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
COMMIT - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
compareTo(Annotation) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
compareTo(SolrSchemaLoader.SolrDynField) - Method in class com.lucidworks.apollo.component.SolrSchemaLoader.SolrDynField
 
COMPONENT - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
Configurable<C extends StageConfig> - Interface in com.lucidworks.apollo.pipeline
Something that can be configured (data source, pipeline stage, aggregation, etc)
Configuration - Interface in com.lucidworks.apollo.pipeline
 
configurationChanged(ConfigurationEvent) - Method in class com.lucidworks.apollo.component.MetricSchedulesRegistrar
 
ConfigurationComponent - Class in com.lucidworks.apollo.component
This component defines the configuration for a given service.
ConfigurationComponent(ZooKeeperConfigurationComponent, MetricRegistry) - Constructor for class com.lucidworks.apollo.component.ConfigurationComponent
Note that this takes in a ZookeeperConfigurationComponent even though it doesn't use it directly.
configureCollectionLayout(Collection, String, org.apache.commons.configuration.Configuration...) - Method in class com.lucidworks.apollo.component.CollectionManager
Configures the numShards, replicationFactor, and maxShardsPerNodes parameters for creating a collection based on configuration settings and the cluster size.
Context - Interface in com.lucidworks.apollo.pipeline
Additional context to pass along with messages in the pipeline
Context.Signal - Class in com.lucidworks.apollo.pipeline
 
CONTEXT_TEMPLATE_KEY - Static variable in class com.lucidworks.apollo.pipeline.index.IndexStage
 
ContextFactory - Interface in com.lucidworks.apollo.pipeline
 
convertPipelineDocumentToSolr(PipelineDocument) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 
convertSolrInputDocumentToPipelineDocument(SolrInputDocument) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 
convertToDoc(UriInfo, Optional<byte[]>, ContainerRequest, long, Optional<byte[]>, ContainerResponse) - Method in class com.lucidworks.apollo.component.AuditComponent
 
convertToDoc(LogEvent) - Method in class com.lucidworks.apollo.component.SolrLoggingComponent.SolrAppender.LogEventConverter
 
counter(String) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
counts - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus
 
create(Pipeline<?>) - Static method in class com.lucidworks.apollo.pipeline.PipelineStatus
 
create(Request, Response, long) - Static method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
create(MultivaluedHashMap, MultivaluedHashMap, MultivaluedHashMap, String) - Static method in class com.lucidworks.apollo.pipeline.query.Request
 
create(MultivaluedHashMap) - Static method in class com.lucidworks.apollo.pipeline.query.Response
 
create(StageAssistFactoryParams) - Method in interface com.lucidworks.apollo.pipeline.StageAssistFactory
 
createCollection(Collection) - Method in class com.lucidworks.apollo.component.CollectionManager
 
createCollection(Collection, boolean) - Method in class com.lucidworks.apollo.component.CollectionManager
 
createItem(String, Map<String, Object>, T) - Method in class com.lucidworks.apollo.component.ItemStore
 
createItem(String, Map<String, Object>, T) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
createPipeline(String, Map<String, String>) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager
Looks up a pipeline definition by id and initializes it.
createPipeline(String, Map<String, String>) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager
 
createStage(String, StageAssistFactoryParams) - Method in interface com.lucidworks.apollo.pipeline.StageFactory
 
CREATOR - Static variable in class com.lucidworks.apollo.common.pipeline.PipelineField
 
curatorAvailable(CuratorComponent) - Method in class com.lucidworks.apollo.component.ItemCache
 
CuratorComponent - Class in com.lucidworks.apollo.component
Manages CuratorFramework instances for the application.
CuratorComponent(DependencyManager, CuratorConfiguration, MetricRegistry, CuratorComponent.InstrumentedBoundedExponentialBackoffRetry) - Constructor for class com.lucidworks.apollo.component.CuratorComponent
 
CuratorServiceRegistryComponent - Class in com.lucidworks.apollo.component
 
CuratorServiceRegistryComponent(CuratorComponent) - Constructor for class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 

D

DEBUG - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
DebugCollectingStageCallback - Class in com.lucidworks.apollo.pipeline
 
DebugCollectingStageCallback() - Constructor for class com.lucidworks.apollo.pipeline.DebugCollectingStageCallback
 
DEFAULT_APP_PORT - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
DEFAULT_CALLBACK - Static variable in class com.lucidworks.apollo.pipeline.index.IndexPipelineManager
 
DEFAULT_METRIC_CLUSTER_NAME - Static variable in class com.lucidworks.apollo.component.MetricLoggingComponent
 
DEFAULT_METRIC_COLLECTION_NAME - Static variable in class com.lucidworks.apollo.component.MetricLoggingComponent
 
DEFAULT_PIPELINE_ID - Static variable in class com.lucidworks.apollo.component.MetricLoggingComponent
 
DEFAULT_SEARCH_LOGS_COLLECTION_SUFFIX - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
DEFAULT_SOLR_STAGE - Static variable in class com.lucidworks.apollo.pipeline.index.DefaultIndexPipelineRegistrar
 
DefaultIndexPipelineRegistrar - Class in com.lucidworks.apollo.pipeline.index
 
DefaultIndexPipelineRegistrar(ObjectMapper) - Constructor for class com.lucidworks.apollo.pipeline.index.DefaultIndexPipelineRegistrar
 
DefaultMetricPipelineRegistrar - Class in com.lucidworks.apollo.pipeline.index
create the default pipeline we'll use to store metrics
DefaultMetricPipelineRegistrar(ObjectMapper) - Constructor for class com.lucidworks.apollo.pipeline.index.DefaultMetricPipelineRegistrar
 
DefaultSearchClusterRegistrar - Class in com.lucidworks.apollo.component
Responsible only for registering the default SearchCluster based on default parameters in the config file, if it doesn't already exist.
DefaultSearchClusterRegistrar(SearchClusterStore, ConfigurationComponent, SearchClusterValidator, ExternalDependencyPoller) - Constructor for class com.lucidworks.apollo.component.DefaultSearchClusterRegistrar
 
DefaultSearchClusterRegistrar.DefaultSearchCluster - Interface in com.lucidworks.apollo.component
 
DefaultSearchClusterRegistrar.SearchClusterWatcher - Class in com.lucidworks.apollo.component
 
DELETE - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
DELETE_QUERY - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
deleteAllItems() - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
deleteAllItems(Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemStore
 
deleteAllItems() - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
deleteAllItems(Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
Returns the IDs of the items deleted.
deleteCollection(String, boolean, boolean, boolean, int) - Method in class com.lucidworks.apollo.component.CollectionManager
 
deleteItem(String) - Method in class com.lucidworks.apollo.component.AbstractItemStore
Delete a item from ZooKeeper
deleteItem(String, int) - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
deleteItem(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
deleteItem(String, Map<String, Object>, int) - Method in class com.lucidworks.apollo.component.ItemStore
 
deleteItem(String) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
deleteItem(String, int) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
deleteItem(String, Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
deleteItem(String, Map<String, Object>, int) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
deleteProperty(String) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
deleteProperty(String, String) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
deleteZKData(CuratorFramework, String, Boolean) - Method in class com.lucidworks.apollo.component.ZKImportExportComponent
 
DOC_TEMPLATE_KEY - Static variable in class com.lucidworks.apollo.pipeline.index.IndexStage
 
DocumentGenerator<C extends StageConfig> - Class in com.lucidworks.apollo.pipeline.index
 
DocumentsEvent - Class in com.lucidworks.apollo.pipeline
 
DocumentsEvent(Stage, Context, String) - Constructor for class com.lucidworks.apollo.pipeline.DocumentsEvent
 
dynFields - Variable in class com.lucidworks.apollo.component.SolrSchemaLoader.SolrSchema
 

E

emptyParams() - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
 
enabled() - Method in class com.lucidworks.apollo.component.AuditComponent
 
EndOfBatchSignal - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
equals(Object) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
equals(Object) - Method in class com.lucidworks.apollo.common.pipeline.Command
 
equals(Object) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
equals(Object) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
equals(Object) - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
equals(Object) - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
 
equals(Object) - Method in class com.lucidworks.apollo.pipeline.StageConfig
A default equals method in case a concrete StageConfig does not provide one.
evaluateConditionalScript(M, Context) - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
EVENT_TYPES - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
EVENTS_COLLECTION - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
EVENTS_PIPELINE - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
EXCLUDE_EXTENSIONS - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
ExecutorComponent - Class in com.lucidworks.apollo.component
A convenience class for creating executor services.
ExecutorComponent(MetricRegistry) - Constructor for class com.lucidworks.apollo.component.ExecutorComponent
 
ExecutorComponent.AbortPolicy - Class in com.lucidworks.apollo.component
Just like the java.util.concurrent.ThreadPoolExecutor.AbortPolicy, but with a better error message.
ExecutorComponent.ListeningExecutorServiceBuilder - Class in com.lucidworks.apollo.component
 
exists(String) - Method in class com.lucidworks.apollo.component.BlobStoreResourceLoader
 
exists(String) - Method in class com.lucidworks.apollo.component.ClasspathResourceLoader
 
exists(String) - Method in interface com.lucidworks.apollo.component.ResourceLoader
 

F

F_RAW_CONTENT - Static variable in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
F_RESERVED_PREFIX - Static variable in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
FeatureStore - Class in com.lucidworks.apollo.component
 
FeatureStore(CuratorComponent, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.FeatureStore
 
fields - Variable in class com.lucidworks.apollo.component.SolrSchemaLoader.SolrSchema
 
finalizeJob(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager
 
finalizeJob(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager
 
fixUnsafeFieldName(String, SolrInputDocument, List<ValidationError>, boolean) - Static method in class com.lucidworks.apollo.component.SolrDocumentValidator
 
fixUnsafeFieldNames(SolrInputDocument, List<ValidationError>, boolean) - Static method in class com.lucidworks.apollo.component.SolrDocumentValidator
 
flatten() - Method in interface com.lucidworks.apollo.pipeline.Context
 
flatten(PipelineDocument) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
Flatten the structure of document.
flush() - Method in class com.lucidworks.apollo.component.BufferingSolrServer
 
flushBuffers() - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
flushCaches() - Method in class com.lucidworks.apollo.component.SearchClusterComponent
Clears all of the internal caches.
flushCollectionId(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
flushSearchClusterId(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
forValue(String) - Static method in enum com.lucidworks.apollo.pipeline.PipelineStateTransition.State
 
fromEventMap(Map<CharSequence, Object>) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 
fromMap(Map<?, ?>) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 
fromSolrDocument(SolrDocument) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 

G

Generator<M,C extends 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(String) - Method in class com.lucidworks.apollo.component.BlobStoreResourceLoader
 
get(String) - Method in class com.lucidworks.apollo.component.ClasspathResourceLoader
 
get() - Method in class com.lucidworks.apollo.component.CuratorComponent
Get an active, initialized CuratorFramework with a namespace set
get() - Method in class com.lucidworks.apollo.component.IgniteComponent
 
get() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
get() - Method in class com.lucidworks.apollo.component.ObjectMapperProvider
 
get(String) - Method in interface com.lucidworks.apollo.component.ResourceLoader
 
get() - Method in class com.lucidworks.apollo.component.ServiceProviderCacheComponent
 
getAdditionalProperties() - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
getAggregatedSearchStats(Collection) - Method in class com.lucidworks.apollo.component.CollectionMetricHelper
Returns a "RequestsAndTime" object that aggregates the # of requests and the total time across all nodes for the given collection.
getAggregatedSearchStats(SolrClient, String) - Method in class com.lucidworks.apollo.component.CollectionMetricHelper
 
getAllFieldNames() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
This method returns all field names, including those that are reserved for internal use.
getAllResourceClients(Class<T>) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getAllResourceClients(Class<T>, <any>) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getAllResourceClients(String) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getAnnotation(int) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getAnnotations() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getAnnotationsSize() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getAppHomeDirectory() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getAppHostname() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getAppPort() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getAppVersion() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getBindAddress() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getBoolean(String, boolean) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Get the value of the property with the given key, or defaultValue if not set.
getBoolean(String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getBoolean(String, boolean) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getBufferingSolrServer(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getBufferingSolrServer(String) - Method in interface com.lucidworks.apollo.component.SolrClientFactory
 
getBuildNumber() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getCached(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry
 
getCollectedOutput() - Method in class com.lucidworks.apollo.pipeline.DebugCollectingStageCallback
 
getCollection(String) - Method in class com.lucidworks.apollo.component.CollectionComponent
 
getCollection(String) - Method in class com.lucidworks.apollo.component.CollectionManager
 
getCollection(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getCollectionMetrics() - Method in class com.lucidworks.apollo.component.SolrMetricLoggingComponent
 
getCollections() - Method in class com.lucidworks.apollo.component.CollectionManager
 
getCommands() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getCommitWithin(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getCommitWithin(String) - Method in interface com.lucidworks.apollo.component.SolrClientFactory
 
getComponentVersions() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getCondition() - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
getConfiguration() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Return the whole configuration.
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
 
getContent() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getContext() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
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
 
getCounters() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getCounters(MetricFilter) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getCreateMode() - Method in class com.lucidworks.apollo.component.ItemStore
 
getCurator(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getDefaultFeature(String) - Method in class com.lucidworks.apollo.component.FeatureStore
 
getDefaultSearchCluster() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getDefaultSearchCluster() - Method in interface com.lucidworks.apollo.component.DefaultSearchClusterRegistrar.DefaultSearchCluster
 
getDelegate() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
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.apollo.component.SearchClusterComponent
 
getDouble(String, double) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Get the value of the property with the given key, or defaultValue if not set.
getDouble(String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getDouble(String, double) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getEnd() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
getErrors() - Method in class com.lucidworks.apollo.pipeline.Pipeline
Collect errors from the stages
getFeatureCount() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
getFeatures() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
getFieldNames() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
This method returns a subset of field names excluding those that are reserved for internal use.
getFieldNames() - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
getFields() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
Return all fields as an (unmodifiable) Map.
getFields(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getFieldValues(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getFieldValues(String) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
getFilteredFieldNames(String...) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
Returns a filtered subset of field names, where names that start with one of excludePrefixes are excluded.
getFirstField(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getFirstFieldValue(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getFirstFieldValue(String) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
getFirstFieldValue(String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getFirstParam(String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getFlattenedFields() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getFloat(String, float) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Get the value of the property with the given key, or defaultValue if not set.
getGauges() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getGauges(MetricFilter) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getGitCommit() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getHeaders() - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getHeaders() - Method in class com.lucidworks.apollo.pipeline.query.Response
 
getHistograms() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getHistograms(MetricFilter) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getHistoricalJobs(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager
 
getHosts() - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
Returns the collection of all of the host:port addresses running in the Apollo system.
getHttpMethod() - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getId() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getId() - Method in class com.lucidworks.apollo.component.NodeIdComponent
 
getId() - Method in class com.lucidworks.apollo.pipeline.AbstractStage
 
getId() - Method in interface com.lucidworks.apollo.pipeline.Configuration
 
getId() - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
 
getId() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getId() - Method in interface com.lucidworks.apollo.pipeline.Stage
 
getId() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams
 
getId() - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
getInflightMessageCount() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getInitialParams() - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getInstance() - Static method in class com.lucidworks.apollo.pipeline.index.NonsenseGenerator
 
getInstanceId() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getInt(String, int) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Get the value of the property with the given key, or defaultValue if not set.
getInt(String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getInt(String, int) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getItem(String) - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
 
getItem(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
 
getItem(String) - Method in class com.lucidworks.apollo.component.ItemCache
 
getItem(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemCache
 
getItem(String) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
getItem(String, Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
getItem(String) - Method in class com.lucidworks.apollo.pipeline.index.IndexPipelineDefinitionCache
 
getItemBytes(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemCache
 
getItemBytes(String, Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
getItemBytes(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemStore
 
getItemHistory(String, String) - Method in class com.lucidworks.apollo.component.HistoryStore
 
getItems() - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
Get all items currently stored in ZooKeeper
getItems(Map<String, Object>) - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
Get all items currently stored in ZooKeeper
getItems() - Method in class com.lucidworks.apollo.component.ItemCache
 
getItems(Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemCache
 
getItems() - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
getItems(Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
getItemStore() - Method in class com.lucidworks.apollo.component.HistoryStore
 
getJerseyClient() - Method in class com.lucidworks.apollo.component.ClientComponent
 
getLabel() - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
getLastField(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getLong(String, int) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Get the value of the property with the given key, or defaultValue if not set.
getLong(String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getLong(String, long) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getMessageClass() - Method in class com.lucidworks.apollo.pipeline.index.DocumentGenerator
 
getMessageClass() - Method in class com.lucidworks.apollo.pipeline.index.IndexStage
 
getMessageClass() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getMessageClass() - Method in interface com.lucidworks.apollo.pipeline.Stage
 
getMetadata() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getMetadata(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getMetadata() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getMetadata(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getMetadataNames() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
getMetadataNames() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getMeters() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getMeters(MetricFilter) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getMetricCollectionName() - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
getMetricCollectionName() - Method in class com.lucidworks.apollo.component.MetricSchedulesRegistrar
 
getMetricRegistry() - Method in class com.lucidworks.apollo.component.ClientComponent
 
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
 
getMetrics() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getMetrics() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getMetricSearchClusterName() - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
getName() - Method in class com.lucidworks.apollo.common.pipeline.Command
 
getName() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getNames() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getNext() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getNodeInfo(CuratorFramework, String, Boolean, List<String>, List<String>, String, Boolean) - Method in class com.lucidworks.apollo.component.ZKImportExportComponent
 
getNumberOfDocuments(SolrClient, String) - Method in class com.lucidworks.apollo.component.CollectionMetricHelper
 
getOrCreateCachedThreadPool(String) - Method in class com.lucidworks.apollo.component.ExecutorComponent
 
getOrCreatePipeline(String, Map<String, String>) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager
Return the current pipeline instance for the given id, or create one
getOrCreatePipeline(String, Map<String, String>) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager
 
getOrCreateSingleThreadExecutor(String, String) - Method in class com.lucidworks.apollo.component.ExecutorComponent
TODO: experimental.
getParam(String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getParams() - Method in class com.lucidworks.apollo.common.pipeline.Command
 
getParams() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
getParams() - Method in class com.lucidworks.apollo.pipeline.query.Request
 
getParentContext() - Method in interface com.lucidworks.apollo.pipeline.Context
Return this context's immediate parent
getPipeline(String) - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager
Return the current pipeline instance for the given id, if it exists
getPipeline(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineManager
 
getPipelineId() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getPipelines() - Method in class com.lucidworks.apollo.pipeline.AbstractPipelineManager
Return a list of the current pipeline instances
getPipelines() - Method in interface com.lucidworks.apollo.pipeline.PipelineManager
 
getProperties() - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getProperties() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getProperties() - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
 
getProperties() - Method in class com.lucidworks.apollo.pipeline.PipelineStateTransition
 
getProperty(String) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
for testing.
getProperty(String) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getProperty(String, T) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getProperty(String, Class<T>) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getProperty(String, <any>) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getProperty(String, T, Class<T>) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getProperty(String, T, <any>) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
getPropertyFromConfigurations(String, T, org.apache.commons.configuration.Configuration...) - Static method in class com.lucidworks.apollo.component.ConfigurationComponent
Returns the value of specified key in the first configuration in which it is found and non-null.
getRecentErrors() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getReservedFieldNames() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
This method returns a subset of field names that are reserved for internal use, i.e.
getResourceClient(Class<T>) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getResourceClient(Class<T>, <any>) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getResourceClient(String) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getResourceClient(String, <any>) - Method in class com.lucidworks.apollo.component.ClientComponent
 
getResourceFactory() - Method in class com.lucidworks.apollo.component.ClientComponent
ClientComponent is meant to wrap ClientResourceFactory, so it's ugly to pierce the veil this way, but there are times when we want access to the underlying factory.
getRunningTimeMs() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getSchemaForCollection(String) - Method in class com.lucidworks.apollo.component.SimpleCachingSolrSchemaLoader
 
getSchemaForCollection(String) - Method in interface com.lucidworks.apollo.component.SolrSchemaLoader
Load schema information for a collection
getSchemaForCollection(String) - Method in class com.lucidworks.apollo.component.ZkAwareCachingSolrSchemaLoader
 
getSearchCluster(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getSearchCluster(Collection) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getSearchClusterStore() - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getSearchLogsClusterName(String) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getSearchLogsCollectionName(String) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
getService(String) - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
getServiceHistory(String) - Method in class com.lucidworks.apollo.component.HistoryStore
 
getServices() - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
getServicesByHost() - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
getServiceStore() - Method in class com.lucidworks.apollo.component.HistoryStore
 
getServiceURIs() - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
getSignal() - Method in interface com.lucidworks.apollo.pipeline.Context
 
getSignal() - Method in class com.lucidworks.apollo.pipeline.Context.Signal
 
getSolrClient() - Method in interface com.lucidworks.apollo.component.SearchClusterComponent.DefaultSolrClient
 
getSolrClientForCollection(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getSolrClientForCollection(String) - Method in interface com.lucidworks.apollo.component.SolrClientFactory
 
getSolrClientForSearchCluster(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getSolrClientForSearchCluster(String) - Method in interface com.lucidworks.apollo.component.SolrClientFactory
 
getSolrServer(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
getSolrServer(String) - Method in interface com.lucidworks.apollo.component.SolrClientFactory
 
getSolrSignalAggrCollection(String) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Return the name of the aggregated signals collection.
getSolrSignalCollection(String) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Return the name of the raw signals collection.
getStage() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
getStageCallback() - Method in interface com.lucidworks.apollo.pipeline.Context
 
getStageConfig() - Method in class com.lucidworks.apollo.pipeline.StageAssistFactoryParams
 
getStageConfigClass() - Method in interface com.lucidworks.apollo.pipeline.Configurable
 
getStageConfigClass() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getStageConfigClass() - Method in interface com.lucidworks.apollo.pipeline.Stage
 
getStageConfigurations() - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
 
getStages() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getStageTypes() - Method in interface com.lucidworks.apollo.pipeline.StageFactory
 
getStart() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
getStartTime() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getState() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
getState() - Method in class com.lucidworks.apollo.pipeline.PipelineStateTransition
 
getString(String, String) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Get the value of the property with the given key, or defaultValue if not set.
getString(String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getString(String, String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
getTask(String) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
 
getTaskName() - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
getTaskName() - Method in class com.lucidworks.apollo.component.SolrMetricLoggingComponent
 
getTimers() - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getTimers(MetricFilter) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
getTotalCollectionCount() - Method in class com.lucidworks.apollo.component.CollectionComponent
This returns the number of collections *that are registered in Apollo.*.
getTrackedCollectionSearchStats() - Method in class com.lucidworks.apollo.component.CollectionMetricHelper
 
getType() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
getType() - Method in class com.lucidworks.apollo.pipeline.AbstractStage
 
getType() - Method in interface com.lucidworks.apollo.pipeline.Configuration
 
getType() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
getType() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
getType() - Method in interface com.lucidworks.apollo.pipeline.Stage
 
getType() - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
getType(Class<? extends StageConfig>) - Static method in class com.lucidworks.apollo.pipeline.StageConfig
 
getUri() - Method in class com.lucidworks.apollo.component.JettyAvailableWatcher.JettyServer
 
getValue() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
getValue() - Method in class com.lucidworks.apollo.pipeline.Context.Signal
 
getZkConfigurationIndex() - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
getZkConnect() - Method in class com.lucidworks.apollo.component.CuratorComponent
 
getZkConnectConfig(SearchCluster) - Static method in class com.lucidworks.apollo.component.SearchClusterValidator
 
GIT_COMMIT - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 

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
 
hasChildren() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
hasCollection(String) - Method in class com.lucidworks.apollo.component.CollectionComponent
 
hasField(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
Return true if this document has the given field.
hashCode() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
hashCode() - Method in class com.lucidworks.apollo.common.pipeline.Command
 
hashCode() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
hashCode() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
hashCode() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
hashCode() - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
 
hashCode() - Method in class com.lucidworks.apollo.pipeline.StageConfig
A default hashCode method in case a concrete StageConfig does not provide one.
hasId() - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
Test if the pipeline has a non-null id
hasItem(String) - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
 
hasItem(String) - Method in class com.lucidworks.apollo.component.ItemCache
 
hasItem(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemCache
 
hasItem(String) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
hasItem(String, Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
hasItem(String, Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemStore
 
hasMetadata(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
hasMetadata(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
hasNext() - Method in class com.lucidworks.apollo.pipeline.index.IndexPipeline.PipelineDocumentIterator
 
hasNext() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
hasParam(String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
hasProperty(String) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
HEADER_BLACKLIST - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
histogram(String) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
HistoryStore - Class in com.lucidworks.apollo.component
 
HistoryStore(CuratorComponent, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.HistoryStore
 
HOST - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
HTTP_METHOD - Static variable in interface com.lucidworks.apollo.pipeline.Context
 

I

IGNITE_GRID_NAME_KEY - Static variable in class com.lucidworks.apollo.component.IgniteComponent
 
IgniteComponent - Class in com.lucidworks.apollo.component
Manages a global reference to Apache Ignite.
IgniteComponent(ConfigurationComponent, CuratorComponent, NodeIdComponent) - Constructor for class com.lucidworks.apollo.component.IgniteComponent
 
IgniteModule - Class in com.lucidworks.apollo.component
Simple module to register Ignite
IgniteModule() - Constructor for class com.lucidworks.apollo.component.IgniteModule
 
IndexPipeline - Class in com.lucidworks.apollo.pipeline.index
 
IndexPipeline(String, String, List<StageConfig>, StageFactory<PipelineDocument>, MetricRegistry, Map<String, String>) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexPipeline
 
IndexPipeline.PipelineDocumentIterator - Class in com.lucidworks.apollo.pipeline.index
Iterator that will read from a queue until it reaches a poison pill object, or a given Future has an error, or reading from the queue times out
IndexPipelineDefinitionCache - Class in com.lucidworks.apollo.pipeline.index
 
IndexPipelineDefinitionCache(CuratorComponent, MetricRegistry, IndexPipelineDefinitionReadWriteStore, ObjectMapper, StringDecryptor) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexPipelineDefinitionCache
 
IndexPipelineDefinitionStore - Class in com.lucidworks.apollo.pipeline.index
 
IndexPipelineDefinitionStore(CuratorComponent, MetricRegistry, ObjectMapper, StringDecryptor, StringEncryptor) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexPipelineDefinitionStore
 
IndexPipelineManager - Class in com.lucidworks.apollo.pipeline.index
 
IndexPipelineManager(IndexPipelineDefinitionRegistry, MetricRegistry, IndexStageConfigReadWriteStore, StageFactory<PipelineDocument>, ObjectMapper, StringEncryptor) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexPipelineManager
 
IndexStage<C extends StageConfig> - Class in com.lucidworks.apollo.pipeline.index
 
IndexStageConfigCache - Class in com.lucidworks.apollo.pipeline.index
 
IndexStageConfigCache(CuratorComponent, MetricRegistry, ObjectMapper, StringDecryptor) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexStageConfigCache
 
IndexStageConfigStore - Class in com.lucidworks.apollo.pipeline.index
 
IndexStageConfigStore(CuratorComponent, MetricRegistry, ObjectMapper, StringEncryptor, StringDecryptor) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexStageConfigStore
 
init(CollectionComponent, SearchClusterComponent.DefaultSolrClient) - Method in class com.lucidworks.apollo.component.AuditComponent
 
init(CuratorComponent) - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
init(SearchClusterStore, DependencyManager) - Method in class com.lucidworks.apollo.component.DefaultSearchClusterRegistrar
 
init(CuratorComponent) - Method in class com.lucidworks.apollo.component.FeatureStore
 
init(CuratorComponent) - Method in class com.lucidworks.apollo.component.HistoryStore
 
init(CuratorComponent) - Method in class com.lucidworks.apollo.component.ItemStore
 
init(CollectionClientResource, SignalAggregatorClientResource, IndexPipelineClientResource, SchedulerClientResource, SearchClusterComponent.DefaultSolrClient) - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
init(SignalAggregatorClientResource, SchedulerClientResource) - Method in class com.lucidworks.apollo.component.MetricSchedulesRegistrar
 
init(DefaultSearchClusterRegistrar.DefaultSearchCluster, DependencyManager, CollectionStore) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
init(CuratorComponent) - Method in class com.lucidworks.apollo.component.ServiceProviderCacheComponent
 
init(CollectionComponent, SearchClusterComponent.DefaultSolrClient) - Method in class com.lucidworks.apollo.component.SolrLoggingComponent
 
init(CuratorComponent, CollectionClientResource, SearchClusterComponent.DefaultSolrClient) - Method in class com.lucidworks.apollo.component.SolrMetricLoggingComponent
 
init(CuratorComponent) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
Start up our ZK ConfigurationSources.
init(AbstractPipelineClientResource, AbstractStageClientResource, ItemReadWriteStore<StageConfig>, ItemReadWriteStore<PipelineDefinition>) - Method in class com.lucidworks.apollo.pipeline.AbstractDefaultPipelineRegistrar
 
init() - Method in class com.lucidworks.apollo.pipeline.AbstractStage
 
init() - Method in interface com.lucidworks.apollo.pipeline.Configurable
 
init(IndexPipelineClientResource, IndexStageClientResource, IndexStageConfigStore, IndexPipelineDefinitionStore) - Method in class com.lucidworks.apollo.pipeline.index.AbstractIndexPipelineRegistrar
 
init() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
initialEntity - Variable in class com.lucidworks.apollo.pipeline.query.Response
 
initializeFactory(CuratorComponent) - Method in class com.lucidworks.apollo.component.ClientComponent
 
instanceId - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus
 
internalEnabled() - Method in class com.lucidworks.apollo.component.AuditComponent
 
isCommandsDocument(PipelineDocument) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
Return true if the given pipeline document is a special "Commands" document.
isInState(Pipeline.State...) - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
isPresent() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
isSchemaless - Variable in class com.lucidworks.apollo.component.SolrSchemaLoader.SolrSchema
 
isSignal() - Method in interface com.lucidworks.apollo.pipeline.Context
 
isSignal(String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
isSkip() - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
isTerminalState() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
ItemAlreadyExistsException() - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemAlreadyExistsException
 
ItemAlreadyExistsException(String) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemAlreadyExistsException
 
ItemAlreadyExistsException(String, Throwable) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemAlreadyExistsException
 
ItemCache<T> - Class in com.lucidworks.apollo.component
Why ItemCache instead of CachingItemStore? In general, the fact that something is locally cached should be an implementation detail -- an optimization hidden from the user.
ItemCache(CuratorComponent, MetricRegistry, String, ItemReader<T>) - Constructor for class com.lucidworks.apollo.component.ItemCache
 
ItemDeserializationException() - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemDeserializationException
 
ItemDeserializationException(String) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemDeserializationException
 
ItemDeserializationException(String, Throwable) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemDeserializationException
 
ItemReadStore<T> - Interface in com.lucidworks.apollo.component
Denotes a thing that reads items from a storage medium (lkely ZK).
ItemReadStore.ItemAndVersion<T> - Class in com.lucidworks.apollo.component
 
ItemReadWriteStore<T> - Interface in com.lucidworks.apollo.component
Marker interface to better facilitate unit testing these things
ItemSerializationException() - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemSerializationException
 
ItemSerializationException(String) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemSerializationException
 
ItemSerializationException(String, Throwable) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemSerializationException
 
ItemStorageException() - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemStorageException
 
ItemStorageException(String) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemStorageException
 
ItemStorageException(String, Throwable) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemStorageException
 
ItemStore<T> - Class in com.lucidworks.apollo.component
A ZK-specific implementation of an AbstractItemStore
ItemStore(CuratorComponent, MetricRegistry, String, ItemReader<T>, ItemWriter<T>) - Constructor for class com.lucidworks.apollo.component.ItemStore
This constructor takes in a CuratorComponent, which allows for deferred initialization (it won't block in the constructor until curator is available).
ItemStore(CuratorFramework, MetricRegistry, String, ItemReader<T>, ItemWriter<T>) - Constructor for class com.lucidworks.apollo.component.ItemStore
 
ItemStore(CuratorFramework, MetricRegistry, String, ItemReader<T>, ItemWriter<T>, CreateMode) - Constructor for class com.lucidworks.apollo.component.ItemStore
 
ItemStore(CuratorComponent, MetricRegistry, ObjectMapper, String, Class<T>) - Constructor for class com.lucidworks.apollo.component.ItemStore
Deprecated.
ItemStoreException - Exception in com.lucidworks.apollo.component
 
ItemStoreException() - Constructor for exception com.lucidworks.apollo.component.ItemStoreException
 
ItemStoreException(String) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException
 
ItemStoreException(String, Throwable) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException
 
ItemStoreException.ItemAlreadyExistsException - Exception in com.lucidworks.apollo.component
 
ItemStoreException.ItemDeserializationException - Exception in com.lucidworks.apollo.component
 
ItemStoreException.ItemSerializationException - Exception in com.lucidworks.apollo.component
 
ItemStoreException.ItemStorageException - Exception in com.lucidworks.apollo.component
 
ItemStoreException.ItemVersionException - Exception in com.lucidworks.apollo.component
 
ItemVersionException() - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemVersionException
 
ItemVersionException(String) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemVersionException
 
ItemVersionException(String, Throwable) - Constructor for exception com.lucidworks.apollo.component.ItemStoreException.ItemVersionException
 
ItemWriteStore<T> - Interface in com.lucidworks.apollo.component
The writing side of an ItemStore.

J

JettyAvailableWatcher - Class in com.lucidworks.apollo.component
Polls for when Jetty is available and listening on the base URI (/api/v1).
JettyAvailableWatcher(ExternalDependencyPoller, ClientComponent, ServiceInstanceFactory) - Constructor for class com.lucidworks.apollo.component.JettyAvailableWatcher
 
JettyAvailableWatcher.JettyServer - Class in com.lucidworks.apollo.component
 
JettyServer(String) - Constructor for class com.lucidworks.apollo.component.JettyAvailableWatcher.JettyServer
 
JobId - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
JSON_FIELD_SET - Static variable in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 

L

Lifecycle - Interface in com.lucidworks.apollo.pipeline
Something that can be started and stopped
LinksEvent - Class in com.lucidworks.apollo.pipeline
 
LinksEvent(Stage, Context) - Constructor for class com.lucidworks.apollo.pipeline.LinksEvent
 
list() - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry
 
listAllItemHistory(String) - Method in class com.lucidworks.apollo.component.HistoryStore
 
listAllServiceHistory() - Method in class com.lucidworks.apollo.component.HistoryStore
 
listCollections() - Method in class com.lucidworks.apollo.component.CollectionComponent
 
listDefaultFeatures() - Method in class com.lucidworks.apollo.component.FeatureStore
 
ListeningExecutorServiceBuilder() - Constructor for class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
 
listItems() - Method in class com.lucidworks.apollo.component.AbstractItemReadStore
List all item id-s currently stored in ZooKeeper
listItems() - Method in class com.lucidworks.apollo.component.ItemCache
 
listItems(Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemCache
 
listItems() - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
listItems(Map<String, Object>) - Method in interface com.lucidworks.apollo.component.ItemReadStore
 
listItems(Map<String, Object>) - Method in class com.lucidworks.apollo.component.ItemStore
 
listResources() - Method in class com.lucidworks.apollo.component.BlobStoreResourceLoader
 
listResources() - Method in class com.lucidworks.apollo.component.ClasspathResourceLoader
 
listResources() - Method in interface com.lucidworks.apollo.component.ResourceLoader
 
log(UriInfo, Optional<byte[]>, ContainerRequest, long, Optional<byte[]>, ContainerResponse) - Method in class com.lucidworks.apollo.component.AuditComponent
 
LogEventConverter() - Constructor for class com.lucidworks.apollo.component.SolrLoggingComponent.SolrAppender.LogEventConverter
 
loggingEnabled() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
logLevel() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 

M

makeHeadline() - Method in class com.lucidworks.apollo.pipeline.index.NonsenseGenerator
Produces something that reads like a headline.
makeSentence(boolean) - Method in class com.lucidworks.apollo.pipeline.index.NonsenseGenerator
Produces a sentence.
makeText(int) - Method in class com.lucidworks.apollo.pipeline.index.NonsenseGenerator
Produces news article text.
matches(String) - Method in class com.lucidworks.apollo.component.SolrSchemaLoader.SolrDynField
 
maybeStop() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
mergeObjectNodes(ObjectNode, ObjectNode) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil
Merge one JsonNode onto the other.
mergePipelines(PipelineDefinition, PipelineDefinition) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil
Merge one pipeline onto another.
message - Variable in class com.lucidworks.apollo.pipeline.RuntimeStage.ThrowableAndMessage
 
meter(String) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
MetricLoggingComponent - Class in com.lucidworks.apollo.component
This currently handles scheduling internally instead of using the Scheduler service, for 2 reasons: 1.) it was simpler; using scheduler would require exposing a "store metrics in Solr now" web service endpoint for no reason other than to allow Scheduler to use it; 2.) Scheduler always executes on only one machine in the cluster, while we want to execute this on *each* machine in the cluster.
MetricLoggingComponent(ConfigurationComponent, CollectionManager, MetricRegistry, CollectionComponent, ClientComponent, CuratorComponent, ScheduledRunnableComponent) - Constructor for class com.lucidworks.apollo.component.MetricLoggingComponent
 
MetricRegistryView - Class in com.lucidworks.apollo.pipeline
A MetricRegistry which presents a "view" of a wrapped MetricRegistry All metric names are automatically prefixed going into the wrapped registry, and stripped of the prefix on the way out.
MetricRegistryView(MetricRegistry, String) - Constructor for class com.lucidworks.apollo.pipeline.MetricRegistryView
 
METRICS_INDEXING_ENABLED - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
MetricSchedulesRegistrar - Class in com.lucidworks.apollo.component
Responsible for registering aggregations and schedules that process data in system_metrics collection.
MetricSchedulesRegistrar(ConfigurationComponent, ClientComponent, CuratorComponent, ScheduledRunnableComponent) - Constructor for class com.lucidworks.apollo.component.MetricSchedulesRegistrar
 
metricsIndexingEnabled() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
metricsKeyPrefix - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 

N

newBuilder() - Method in class com.lucidworks.apollo.component.ExecutorComponent
 
newCachedThreadPool(String) - Method in class com.lucidworks.apollo.component.ExecutorComponent
Creates a thread pool that creates new threads as needed, but will reuse previously constructed threads when they are available.
newChildContext() - Method in interface com.lucidworks.apollo.pipeline.Context
 
newChildContext(StageCallback<?>) - Method in interface com.lucidworks.apollo.pipeline.Context
 
newCommit() - Static method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
newContext() - Method in interface com.lucidworks.apollo.pipeline.ContextFactory
 
newContext(StageCallback<?>) - Method in interface com.lucidworks.apollo.pipeline.ContextFactory
 
newDelete(String, boolean) - Static method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
newDeleteByQuery(String, boolean) - Static method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
newDocument() - Static method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
newDocument(String) - Static method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
newFixedThreadPool(int, String) - Method in class com.lucidworks.apollo.component.ExecutorComponent
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.
newId(String) - Method in class com.lucidworks.apollo.pipeline.PipelineDefinition
Create a copy of this pipeline with a new id
newId(ObjectMapper, T, String) - Static method in class com.lucidworks.apollo.pipeline.StageConfig
 
newRequest(<any>, <any>, String) - Static method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
newSingleThreadExecutor(String) - Method in class com.lucidworks.apollo.component.ExecutorComponent
 
next() - Method in class com.lucidworks.apollo.pipeline.index.IndexPipeline.PipelineDocumentIterator
 
next() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
NODE_ID_KEY - Static variable in class com.lucidworks.apollo.component.NodeIdComponent
 
NodeIdComponent - Class in com.lucidworks.apollo.component
Manages a persistent identifier for this node.
NodeIdComponent(ConfigurationComponent) - Constructor for class com.lucidworks.apollo.component.NodeIdComponent
 
NonsenseGenerator - Class in com.lucidworks.apollo.pipeline.index
 

O

ObjectMapperProvider - Class in com.lucidworks.apollo.component
 
ObjectMapperProvider() - Constructor for class com.lucidworks.apollo.component.ObjectMapperProvider
 
of(T, int) - Static method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
of(T, boolean, int) - Static method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
onAvailable(SolrClient) - Method in interface com.lucidworks.apollo.component.SearchClusterComponent.SolrClientAvailableCallback
 
onCollectionAdded(String) - Method in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware
 
onCollectionAdded(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
onCollectionRemoved(String) - Method in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware
 
onCollectionRemoved(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
onCollectionUpdated(String) - Method in interface com.lucidworks.apollo.component.CollectionComponent.CollectionChangeAware
 
onCollectionUpdated(String) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
onFinished(Runnable) - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator
 
onFinished(Runnable) - Method in interface com.lucidworks.apollo.pipeline.Generator
 
onResourceAvailable(Class<T>, ClientResourceFactory.ResourceAvailableCallback<T>) - Method in class com.lucidworks.apollo.component.ClientComponent
If the resource is already available, it will be called immediately.
onSearchClusterAvailable(String, SearchClusterComponent.SolrClientAvailableCallback) - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
onStageEmit(PipelineDocument, Context, String, StageConfig, boolean) - Method in class com.lucidworks.apollo.pipeline.DebugCollectingStageCallback
 
onStageEmit(M, Context, String, StageConfig, boolean) - Method in interface com.lucidworks.apollo.pipeline.StageCallback
 
onStageError(PipelineDocument, Context, String, StageConfig, Throwable) - Method in class com.lucidworks.apollo.pipeline.DebugCollectingStageCallback
 
onStageError(M, Context, String, StageConfig, Throwable) - Method in interface com.lucidworks.apollo.pipeline.StageCallback
 
onStageEvent(Object) - Method in class com.lucidworks.apollo.pipeline.DebugCollectingStageCallback
 
onStageEvent(Object) - Method in interface com.lucidworks.apollo.pipeline.StageCallback
 
or(T) - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
orNull() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
overwriteCollection(String, int, Collection) - Method in class com.lucidworks.apollo.component.CollectionManager
 

P

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.State - Enum in com.lucidworks.apollo.pipeline
 
PipelineDefinition - Class in com.lucidworks.apollo.pipeline
Definition of a pipeline (its stages and properties)
PipelineDefinition(String, List<StageConfig>) - Constructor for class com.lucidworks.apollo.pipeline.PipelineDefinition
 
PipelineDefinition(String, List<StageConfig>, Map<String, String>) - Constructor for class com.lucidworks.apollo.pipeline.PipelineDefinition
 
PipelineDefinitionMergeUtil - Class in com.lucidworks.apollo.pipeline
 
PipelineDefinitionMergeUtil() - Constructor for class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil
 
PipelineDefinitionRegistry - Interface in com.lucidworks.apollo.pipeline
 
PipelineDocument - Class in com.lucidworks.apollo.common.pipeline
Fusion internal representation of a "SolrDocument".
PipelineDocument() - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
PipelineDocument(String) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
PipelineDocument(String, List<PipelineField>, Map<String, String>, List<Command>) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
PipelineDocument(PipelineDocument) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
PipelineDocumentIterator(BlockingQueue<PipelineDocument>, PipelineDocument, Future<?>, long) - Constructor for class com.lucidworks.apollo.pipeline.index.IndexPipeline.PipelineDocumentIterator
 
PipelineDocumentUtils - Class in com.lucidworks.apollo.pipeline.index
 
PipelineDocumentUtils() - Constructor for class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 
PipelineErrors - Class in com.lucidworks.apollo.pipeline
 
PipelineErrors() - Constructor for class com.lucidworks.apollo.pipeline.PipelineErrors
 
PipelineEvent<T> - Class in com.lucidworks.apollo.pipeline
 
PipelineEvent(Stage, Context, String, Map<String, Object>) - Constructor for class com.lucidworks.apollo.pipeline.PipelineEvent
 
PipelineField - Class in com.lucidworks.apollo.common.pipeline
 
PipelineField() - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineField
 
PipelineField(String, Object) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineField
 
PipelineField(String, Object, String...) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineField
 
PipelineField(String, Object, Map<String, String>) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineField
 
PipelineField(String, Object, List<Annotation>) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineField
 
PipelineField(String, Object, Map<String, String>, List<Annotation>) - Constructor for class com.lucidworks.apollo.common.pipeline.PipelineField
 
PipelineId - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
pipelineId - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus
 
PipelineInitError - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
PipelineManager<M> - Interface in com.lucidworks.apollo.pipeline
 
PipelineRuntimeError - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
PipelineStateTransition - Class in com.lucidworks.apollo.pipeline
POJO used by the API to transition a Pipeline from one state to another TODO how to reduce redundancy between this State and the Pipeline.State?
PipelineStateTransition(PipelineStateTransition.State, Map<String, String>) - Constructor for class com.lucidworks.apollo.pipeline.PipelineStateTransition
 
PipelineStateTransition.State - Enum in com.lucidworks.apollo.pipeline
 
PipelineStatus - Class in com.lucidworks.apollo.pipeline
Represents a snapshot of the Pipeline's state.
PORT - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
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(PipelineDocument, Context) - Method in class com.lucidworks.apollo.pipeline.index.SimpleIndexStage
 
process(PipelineDocument, Context, StageOutput<PipelineDocument>) - Method in class com.lucidworks.apollo.pipeline.index.SimpleIndexStage
 
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 Also collect some metrics and handle errors
Processor<M> - Interface in com.lucidworks.apollo.pipeline
Something that can accept and process a message
putAll(<any>) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
putDefaultFeature(FeatureSpec) - Method in class com.lucidworks.apollo.component.FeatureStore
 
putItem(String, T) - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
putItem(String, T, int) - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
putItem(String, Map<String, Object>, T) - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
putItem(String, Map<String, Object>, T, int) - Method in class com.lucidworks.apollo.component.AbstractItemStore
A put-or-create version of putItem.
putItem(String, T, int, boolean) - Method in class com.lucidworks.apollo.component.AbstractItemStore
 
putItem(String, Map<String, Object>, T, int, boolean) - Method in class com.lucidworks.apollo.component.ItemStore
 
putItem(String, T) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
putItem(String, T, int) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
putItem(String, Map<String, Object>, T) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
putItem(String, Map<String, Object>, T, int) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
putItem(String, T, int, boolean) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
putItem(String, Map<String, Object>, T, int, boolean) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
TODO doc me
putParams(String, List<String>) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
putSingleParam(String, String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
putSingleParamIfAbsent(String, String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 

Q

QUERY - Static variable in class com.lucidworks.apollo.common.pipeline.Command
 
QueryRequestAndResponse - Class in com.lucidworks.apollo.pipeline.query
 

R

RAW_CONTENT_FIELD_NAME - Static variable in class com.lucidworks.apollo.component.CollectionManager
 
refresh() - Method in class com.lucidworks.apollo.component.ItemCache
 
register(String, String, int, ResourceDescriptor, String) - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
register(<any>) - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
register(String, T) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
register(PipelineDefinition) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry
 
registerAll(MetricSet) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
rejectedExecution(Runnable, ThreadPoolExecutor) - Method in class com.lucidworks.apollo.component.ExecutorComponent.AbortPolicy
Always throws RejectedExecutionException.
remove() - Method in class com.lucidworks.apollo.pipeline.index.IndexPipeline.PipelineDocumentIterator
 
remove(String) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
remove() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
removeAnnotation(int) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
removeFields(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
Remove all fields from document that match the given field name.
removeFields(String) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
removeListener(MetricRegistryListener) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
removeMatching(MetricFilter) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
removeMetadata(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
removeMetadata(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
removeParam(String) - Method in class com.lucidworks.apollo.pipeline.query.Request
 
removeProperty(String) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
removeProperty(String, T) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
rename(String, FieldMappingRule) - Static method in class com.lucidworks.apollo.component.SolrDocumentValidator
Rename an offending field to a dynamic field.
replaceItem(String, Map<String, Object>, T, int) - Method in class com.lucidworks.apollo.component.ItemStore
 
replaceItem(String, Map<String, Object>, T, int) - Method in interface com.lucidworks.apollo.component.ItemWriteStore
 
report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>) - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
report(SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>, Map<String, Object>) - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
report(String, int, SortedMap<String, Gauge>, SortedMap<String, Counter>, SortedMap<String, Histogram>, SortedMap<String, Meter>, SortedMap<String, Timer>, Map<String, Object>) - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
report() - Method in class com.lucidworks.apollo.component.SolrMetricLoggingComponent
 
request(SolrRequest, String) - Method in class com.lucidworks.apollo.component.BufferingSolrServer
 
request - Variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
REQUEST - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
Request - Class in com.lucidworks.apollo.pipeline.query
 
Request(<any>, <any>, String) - Constructor for class com.lucidworks.apollo.pipeline.query.Request
 
REQUEST_ENTITY - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
REQUEST_HANDLER - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
REQUEST_HEADER_PREFIX - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
REQUEST_HEADERS - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
REQUEST_HTTP_METHOD - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
REQUEST_MEDIA_TYPE - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
REQUEST_METHOD - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
REQUEST_PARAM_PREFIX - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
REQUEST_PARAMS - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
REQUEST_PARAMS - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
REQUEST_PATH - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
REQUEST_URI - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
requests - Variable in class com.lucidworks.apollo.component.CollectionMetricHelper.RequestsAndTime
 
RequestsAndTime(long, double) - Constructor for class com.lucidworks.apollo.component.CollectionMetricHelper.RequestsAndTime
 
ResourceLoader - Interface in com.lucidworks.apollo.component
 
response - Variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
RESPONSE - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
Response - Class in com.lucidworks.apollo.pipeline.query
 
Response(<any>, Object) - Constructor for class com.lucidworks.apollo.pipeline.query.Response
 
RESPONSE_ENTITY - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
RESPONSE_ENTITY - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
RESPONSE_ENTITY_TYPE_ACTUAL - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
RESPONSE_ENTITY_TYPE_DECLARED - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
RESPONSE_HEADER_PREFIX - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
RESPONSE_HEADERS - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
RESPONSE_MEDIA_TYPE - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
RESPONSE_STATUS - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
RESPONSE_TRANSFORMER - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
runCallbackForFeature(CallParams, Feature) - Method in class com.lucidworks.apollo.component.CollectionManager
 
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(Stage<M, C>, C, <any>, MetricRegistry) - Constructor for class com.lucidworks.apollo.pipeline.RuntimeStage
 
RuntimeStage.ThrowableAndMessage<M> - Class in com.lucidworks.apollo.pipeline
 

S

scheduleAtFixedRate(String, Runnable, long, long, TimeUnit) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period; that is executions will commence after initialDelay then initialDelay+period, then initialDelay + 2 * period, and so on.
ScheduledRunnableComponent - Class in com.lucidworks.apollo.component
A simple component to centralize the various scheduled tasks we have in the system.
ScheduledRunnableComponent() - Constructor for class com.lucidworks.apollo.component.ScheduledRunnableComponent
 
scheduleOnce(String, Runnable, long, TimeUnit) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
Creates and executes a one-shot action that becomes enabled after the given delay.
scheduleOnce(String, Callable<T>, long, TimeUnit) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
Creates and executes a ScheduledFuture that becomes enabled after the given delay.
scheduleUntilSuccessful(String, Callable<Boolean>, long, long, TimeUnit) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
 
scheduleWithFixedDelay(String, Runnable, long, long, TimeUnit) - Method in class com.lucidworks.apollo.component.ScheduledRunnableComponent
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given delay between the termination of one execution and the commencement of the next.
SearchClusterComponent - Class in com.lucidworks.apollo.component
Provides access to the Solr servers associated with a given collectionId.
SearchClusterComponent(SearchClusterStore, CollectionComponent, ClientComponent, ConfigurationComponent, MetricRegistry, ScheduledRunnableComponent, Ignite) - Constructor for class com.lucidworks.apollo.component.SearchClusterComponent
 
SearchClusterComponent.DefaultSolrClient - Interface in com.lucidworks.apollo.component
Represents the solrClient for the "Default" solr cluster.
SearchClusterComponent.SolrClientAvailableCallback - Interface in com.lucidworks.apollo.component
 
SearchClusterStore - Class in com.lucidworks.apollo.component
Stores records about search clusters -- i.e.
SearchClusterStore(CuratorComponent, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.SearchClusterStore
 
SearchClusterValidator - Class in com.lucidworks.apollo.component
 
SearchClusterValidator(ClientComponent, MetricRegistry) - Constructor for class com.lucidworks.apollo.component.SearchClusterValidator
 
SearchClusterWatcher(DependencyManager) - Constructor for class com.lucidworks.apollo.component.DefaultSearchClusterRegistrar.SearchClusterWatcher
 
searchLogsClusterNameKeyPrefix - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
send(M, Context) - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator
 
send(M, Map<String, String>) - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
send(M, Map<String, String>, StageCallback<M>) - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
send(M, Context) - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
send(Iterator<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
 
ServiceProviderCacheComponent - Class in com.lucidworks.apollo.component
Simple singleton wrapper around ServiceProviderCache
ServiceProviderCacheComponent(CuratorComponent, ConfigurationComponent) - Constructor for class com.lucidworks.apollo.component.ServiceProviderCacheComponent
 
set(String, Object) - Method in interface com.lucidworks.apollo.pipeline.Context
 
setAnnotations(List<Annotation>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
setCallback(String, ConfigurationListener) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
ConfigurationListener will be called when the given configuration key is modified on any node.
setCondition(String) - Method in class com.lucidworks.apollo.pipeline.StageConfig
 
setContent(byte[]) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
setCorePoolSize(int) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
 
setEnd(long) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
setField(String, Object) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
Set the value of the given field to the given value.
setField(String, Object, String...) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
setField(String, Object, List<Annotation>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
setField(String, Object) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
setFields(Map<String, List<PipelineField>>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
Set all fields for this document by clearing existing fields and adding all content from the given fields Map.
setFields(String, Collection<?>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
setFields(String, Collection<?>) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
setHandler(RejectedExecutionHandler) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
 
setId(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
setKeepAliveTime(long, TimeUnit) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
The amount of time
setMaximumPoolSize(int) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
The ExecutorService will always prefer adding tasks to the queue over adding threads beyond the core pool size.
setMetadata(Map<String, String>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
setMetadata(Map<String, String>) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
setName(String) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
setOverrideProperty(String, Object) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
setProperties(Map<String, Object>) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
setProperty(String, Object) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
setProperty(String, String, Object) - Method in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
setProperty(String, Object) - Method in interface com.lucidworks.apollo.pipeline.Context
Deprecated.
setShared(String, Object) - Method in interface com.lucidworks.apollo.pipeline.Context
 
setSignal(String, String) - Method in interface com.lucidworks.apollo.pipeline.Context
 
setStageOutput(StageOutput<M>) - Method in class com.lucidworks.apollo.pipeline.AbstractGenerator
 
setStart(long) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
setThreadNameFormat(String) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
 
setThreadPoolName(String) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
Set the name of this thread pool.
setType(String) - Method in class com.lucidworks.apollo.common.pipeline.Annotation
 
setValue(Object) - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
setWithMetrics(boolean) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
 
setWorkQueue(BlockingQueue<Runnable>) - Method in class com.lucidworks.apollo.component.ExecutorComponent.ListeningExecutorServiceBuilder
This will almost always be a SynchronousQueue or an ArrayBlockingQueue with a reasonable maximum size.
shutdown() - Method in class com.lucidworks.apollo.component.BufferingSolrServer
 
shutdown() - Method in class com.lucidworks.apollo.component.ClientComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.CuratorComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.IgniteComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.ItemCache
 
shutdown() - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.SearchClusterComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.ServiceProviderCacheComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.SolrLoggingComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.SolrMetricLoggingComponent
 
shutdown() - Method in class com.lucidworks.apollo.component.ZkAwareCachingSolrSchemaLoader
 
Signal - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
Signal(String, String) - Constructor for class com.lucidworks.apollo.pipeline.Context.Signal
 
SIGNALS_INGEST_FIELD_MAPPING_STAGE - Static variable in class com.lucidworks.apollo.pipeline.index.DefaultIndexPipelineRegistrar
 
SIGNALS_INGEST_FORMATTER_STAGE - Static variable in class com.lucidworks.apollo.pipeline.index.DefaultIndexPipelineRegistrar
 
SIGNALS_SOLR_STAGE - Static variable in class com.lucidworks.apollo.pipeline.index.DefaultIndexPipelineRegistrar
 
SignalTypeStore - Class in com.lucidworks.apollo.component
 
SignalTypeStore(CuratorComponent, MetricRegistry, ObjectMapper) - Constructor for class com.lucidworks.apollo.component.SignalTypeStore
 
SimpleCachingSolrSchemaLoader - Class in com.lucidworks.apollo.component
Caches Solr schema in a guava cache with configurable cache size and expiration time
SimpleCachingSolrSchemaLoader(SearchClusterComponent, CollectionStore, CollectionComponent, ConfigurationComponent) - Constructor for class com.lucidworks.apollo.component.SimpleCachingSolrSchemaLoader
 
SimpleIndexStage<C extends StageConfig> - Class in com.lucidworks.apollo.pipeline.index
 
Simulate - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
SIMULATE - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
size() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
SOLR_BUFFER_CONCURRENCY - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SOLR_BUFFER_FLUSH_INTERVAL - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SOLR_BUFFER_SIZE - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SOLR_COMMIT_WITHIN - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SOLR_ZK_CLIENT_TIMEOUT - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SOLR_ZK_CONNECT - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SOLR_ZK_CONNECT_TIMEOUT - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SolrAppender(SolrClient, String, String) - Constructor for class com.lucidworks.apollo.component.SolrLoggingComponent.SolrAppender
 
solrBufferConcurrency - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
solrBufferFlushInterval - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
solrBufferSize - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SolrClientFactory - Interface in com.lucidworks.apollo.component
Represents a component that can return SolrClients.
SolrCommitSignal - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
solrCommitWithin - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
SolrDeleteByIdSignal - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
SolrDeleteByQuerySignal - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
SolrDocumentValidator - Class in com.lucidworks.apollo.component
 
SolrDocumentValidator(SolrSchemaLoader) - Constructor for class com.lucidworks.apollo.component.SolrDocumentValidator
 
SolrLoggingComponent - Class in com.lucidworks.apollo.component
 
SolrLoggingComponent(SearchClusterComponent, CollectionComponent, CollectionManager, ConfigurationComponent, CuratorComponent, SearchClusterStore) - Constructor for class com.lucidworks.apollo.component.SolrLoggingComponent
 
SolrLoggingComponent.SolrAppender - Class in com.lucidworks.apollo.component
 
SolrLoggingComponent.SolrAppender.LogEventConverter - Class in com.lucidworks.apollo.component
 
SolrMetricLoggingComponent - Class in com.lucidworks.apollo.component
Log statistics coming from Solr back into a Solr collection
SolrMetricLoggingComponent(ConfigurationComponent, CollectionManager, MetricRegistry, CollectionComponent, ClientComponent, CuratorComponent, ScheduledRunnableComponent) - Constructor for class com.lucidworks.apollo.component.SolrMetricLoggingComponent
 
SolrSchema(boolean, Map<String, SolrField>, List<SolrSchemaLoader.SolrDynField>, String) - Constructor for class com.lucidworks.apollo.component.SolrSchemaLoader.SolrSchema
 
SolrSchemaLoader - Interface in com.lucidworks.apollo.component
 
SolrSchemaLoader.SolrDynField - Class in com.lucidworks.apollo.component
 
SolrSchemaLoader.SolrSchema - Class in com.lucidworks.apollo.component
 
solrZKClientTimeout - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
solrZkConnect - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
solrZkConnectTimeout - Variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
split(String) - Method in class com.lucidworks.apollo.component.ConfigurationComponent
Uses the splitter returned by ConfigurationComponent.getSplitter() to split the given value into a list.
Stage<M,C extends StageConfig> - Interface in com.lucidworks.apollo.pipeline
The basic unit of a pipeline, a stage
STAGE_INDEX - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
StageAssistFactory<M,T extends Stage<M,? extends 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) - Constructor for class com.lucidworks.apollo.pipeline.StageAssistFactoryParams
 
StageCallback<M> - Interface in com.lucidworks.apollo.pipeline
 
StageConfig - Class in com.lucidworks.apollo.pipeline
Base class for configuration POJOs
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.
StageOutput<M> - Interface in com.lucidworks.apollo.pipeline
Something for stages to write messages to
stagesAsMap(PipelineDefinition) - Static method in class com.lucidworks.apollo.pipeline.PipelineDefinitionMergeUtil
Index StageConfigs into a Map for easy lookup
start(long, TimeUnit) - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
start(long, long, TimeUnit) - Method in class com.lucidworks.apollo.component.MetricLoggingComponent
 
start() - Method in interface com.lucidworks.apollo.pipeline.Lifecycle
 
start() - Method in class com.lucidworks.apollo.pipeline.Pipeline
 
start() - Method in class com.lucidworks.apollo.pipeline.RuntimeStage
 
startTime - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus
 
state - Variable in class com.lucidworks.apollo.pipeline.PipelineStatus
 
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
 
STORE_PATH - Static variable in class com.lucidworks.apollo.component.SearchClusterStore
 
STORE_PATH - Static variable in class com.lucidworks.apollo.component.SignalTypeStore
 
stringifyValues(Collection<Object>) - Static method in class com.lucidworks.apollo.component.SolrDocumentValidator
 
syncFlush() - Method in class com.lucidworks.apollo.component.BufferingSolrServer
 

T

t - Variable in class com.lucidworks.apollo.pipeline.RuntimeStage.ThrowableAndMessage
 
ThrowableAndMessage(M, Throwable) - Constructor for class com.lucidworks.apollo.pipeline.RuntimeStage.ThrowableAndMessage
 
ThrowOnError - Static variable in interface com.lucidworks.apollo.pipeline.Context
 
TIME - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
timer(String) - Method in class com.lucidworks.apollo.pipeline.MetricRegistryView
 
TIMESTAMP - Static variable in class com.lucidworks.apollo.component.AuditComponent
 
toMap(PipelineDocument) - Static method in class com.lucidworks.apollo.pipeline.index.PipelineDocumentUtils
 
toOptional() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
toString() - Method in class com.lucidworks.apollo.common.pipeline.Annotation
Returns a String representation of the Annotation
toString() - Method in class com.lucidworks.apollo.common.pipeline.Command
 
toString() - Method in class com.lucidworks.apollo.common.pipeline.PipelineDocument
 
toString() - Method in class com.lucidworks.apollo.common.pipeline.PipelineField
 
toString() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 
toString() - Method in class com.lucidworks.apollo.component.JettyAvailableWatcher.JettyServer
 
toString() - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 
toString() - Method in enum com.lucidworks.apollo.pipeline.PipelineStateTransition.State
 
toString() - Method in class com.lucidworks.apollo.pipeline.PipelineStatus
 
TOTAL_TIME - Static variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
totalTime - Variable in class com.lucidworks.apollo.component.CollectionMetricHelper.RequestsAndTime
 
totalTime - Variable in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
TRANSFORMER - Static variable in class com.lucidworks.apollo.pipeline.PipelineStatus
 

U

uniqueKey - Variable in class com.lucidworks.apollo.component.SolrSchemaLoader.SolrSchema
 
Unknown - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
UnknownPipeline - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
UnknownStage - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
UnknownStageType - Static variable in class com.lucidworks.apollo.pipeline.PipelineErrors
 
unregister(<any>) - Method in class com.lucidworks.apollo.component.CuratorServiceRegistryComponent
 
unregister(String) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry
 
UNSAFE_PATTERN - Static variable in class com.lucidworks.apollo.component.SolrDocumentValidator
 
update(String, PipelineDefinition) - Method in interface com.lucidworks.apollo.pipeline.PipelineDefinitionRegistry
 
updateZKData(CuratorFramework, Boolean, List<String>, List<String>, Boolean, ZNodeDump) - Method in class com.lucidworks.apollo.component.ZKImportExportComponent
 
uploadZKData(CuratorFramework, Boolean, List<String>, List<String>, ZNodeDump) - Method in class com.lucidworks.apollo.component.ZKImportExportComponent
 
USAGE_MONITOR - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
USAGE_MONITOR_TEST_MODE - Static variable in class com.lucidworks.apollo.component.ConfigurationComponent
 
usageMonitorEnabled() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 
usageMonitorTestMode() - Method in class com.lucidworks.apollo.component.ConfigurationComponent
 

V

validate(SearchCluster) - Method in class com.lucidworks.apollo.component.SearchClusterValidator
 
validateDocument(String, SolrInputDocument, DateUtils, boolean, boolean, FieldMappingRule) - Method in class com.lucidworks.apollo.component.SolrDocumentValidator
 
valueOf(String) - Static method in enum com.lucidworks.apollo.pipeline.Pipeline.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.lucidworks.apollo.pipeline.PipelineStateTransition.State
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.lucidworks.apollo.pipeline.Pipeline.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.lucidworks.apollo.pipeline.PipelineStateTransition.State
Returns an array containing the constants of this enum type, in the order they are declared.
VAR_DIR_KEY - Static variable in class com.lucidworks.apollo.component.NodeIdComponent
 
version() - Method in class com.lucidworks.apollo.component.ItemReadStore.ItemAndVersion
 

W

withResponse(<any>, Object, long) - Method in class com.lucidworks.apollo.pipeline.query.QueryRequestAndResponse
 
WithSideEffects - Interface in com.lucidworks.apollo.pipeline
Marker interface to indicate a Stage has side-effects
write(T) - Method in class com.lucidworks.apollo.pipeline.PipelineEvent
 

Z

ZK_CONFIG_ROOT_PATH - Static variable in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
ZK_CONFIG_UPDATE_ALLOWED_KEY - Static variable in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
ZK_DEFAULT_CONFIG_ROOT_PATH - Static variable in class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
ZK_PATH - Static variable in class com.lucidworks.apollo.pipeline.index.IndexPipelineDefinitionStore
 
ZK_PATH - Static variable in class com.lucidworks.apollo.pipeline.index.IndexStageConfigStore
 
ZkAwareCachingSolrSchemaLoader - Class in com.lucidworks.apollo.component
Invalidates SimpleCachingSolrSchemaLoader's cache on Zk's watcher events
ZkAwareCachingSolrSchemaLoader(SearchClusterComponent, CollectionStore, CollectionComponent, ConfigurationComponent) - Constructor for class com.lucidworks.apollo.component.ZkAwareCachingSolrSchemaLoader
 
ZKImportExportComponent - Class in com.lucidworks.apollo.component
Provides CRUD access to the data inside Zookeeper.
ZKImportExportComponent() - Constructor for class com.lucidworks.apollo.component.ZKImportExportComponent
 
ZooKeeperConfigurationComponent - Class in com.lucidworks.apollo.component
Creates ZK-backed configuration objects, via Netflix Archaius and Apache Commons Configuration.
ZooKeeperConfigurationComponent(CuratorComponent, ObjectMapperJaxRsProvider) - Constructor for class com.lucidworks.apollo.component.ZooKeeperConfigurationComponent
 
ZooKeeperConfigurationSource - Class in com.lucidworks.apollo.component
This extends Archaius's ZooKeeperConfigurationSource because it depends on an old version of Guava and throws exceptions on close.
ZooKeeperConfigurationSource(CuratorFramework, String) - Constructor for class com.lucidworks.apollo.component.ZooKeeperConfigurationSource
Creates the pathChildrenCache using the CuratorFramework client and ZK root path node for the config
A B C D E F G H I J L M N O P Q R S T U V W Z 
Skip navigation links