All Classes and Interfaces
Class
Description
AbstractCrudEntityValidator<E extends com.lucidworks.apollo.common.objects.Entity>
provide validation logic for entities that are used by the AbstractCrudResource that cannot be achieved with existing schema validation facilities.
Bridge between PipelineDefinitionRegistry and ItemStore
Manages the set of currently known Pipelines
TODO extract an interface for the history stuff, store history in Solr
Something that is intended to be auto-discovered by classpath scanning.
Contract for all components to fulfill basic pipeline requirements.
File system for GraalVM context, allows to import the javascript files from blob store, in a convenient way like from file
Simple class that wraps a
SolrClient instance and adds a simple buffer on top of it.An abstract call to a remote endpoint.
Builds a particular
Call implementation.This component uses a registry of known
Call implementations to
create appropriate implementation based on URI scheme.Part of JavaScript API
You can use in a way:
function (request, response, ctx) {
var spec = callFactory.builder('get', 'service: //admin/something');
spec.entity='body';
resp = JSON.parse(spec.exchange()['entity']);
ctx.setProperty('status', resp.status);
}
Does basic data reading involving collections.
Store collection metadata in ZooKeeper
Load config objects from a system resource
Expects a JSON file with an object of objects which map to POJOs
Configurable<C extends com.lucidworks.apollo.pipeline.StageConfig>
Something that can be configured (data source, pipeline stage, aggregation, etc)
Copy secrets from another pipeline if
PipelineConstants.SECRET_SOURCE_PIPELINE_ID is setConfiguration for Curator framework
manages the creation and caretaking of data sources as described by their descriptors
ItemReader that decrypts secrets (e.g.Base implementation of the BasePipelineComponent.
Default assignment strategy just selects the configured Solr collection to send documents to, i.e.
A convenience class for creating executor services.
Just like the java.util.concurrent.ThreadPoolExecutor.AbortPolicy, but with a better error message.
A strategy for assigning documents to Solr collections.
ItemWriter that encrypts secrets (e.g.convenience constants class to hold metric literals and their descriptions
Adds the Fusion node filter transformer to a default list of SolrJ transformers.
Fusion exception which can extract some important information form Solr excepting
A stateful stage that generates documents
Since a Generator can stop itself, it adds an onFinished listener
Factory interface for creating GraalVM JavaScript contexts with different security configurations.
Overrides the default RESTError serialization logic to limit the stack trace verbosity;
has to be public static to be instantiated by JSON framework.
Builder for
HttpCall.Extracts from response only requested paths and add them to returned map in a flat manner.
Helper class to transform a
Document to a org.w3c.dom.Document,
for integration with toolsets that use the W3C DOM.Something that can be started and stopped
Traverse an object and extract
LinksCreated to provide alternative sources of Javascript than a typical Javascript stage.
Deprecated.
we have a control over the script engine, and we should not use not compilable engines
I hope this class is not really used anywhere
Main runtime support for a pipeline (the actual thing that runs)
Controls wiring the stages together, starting, and stopping them.
Create a new client object that connects to Zookeeper and is always aware
of the SolrCloud state.
Deprecated.
is it used anywhere?
Represents a snapshot of the Pipeline's state.
Something that can accept and process a message
Base implementation for a
MessageBodyWriter that performs redaction of sensitive dataCommon code between IndexingRPCStage and RPCQueryStage
Decorates a Stage instance with some telemetry and bounds checking
Extract links by using a
SchemaProcessor.Simple static "factory" for Javascript ScriptEngine instances
Stores records about search clusters -- i.e.
A pool that holds a single value and return it on borrowObject.
Solr users can do federated search using "collection" or "shards" query params,
thus bypassing our security enforcements.
Provides access to the Solr servers associated with a given collectionId.
Class to remember the requested collection.
Discovery client for Search Solr clusters.
Discovery client for Search Solr clusters.
Interface which is implemented by different classes which will be used to capture the solr metrics.
Factory for native solr client to create a metrics collector based on type of request
Stores metric information accumulated during processing of a Solr query.
Helper class for common SQL tasks like getting data sources, etc.
The basic unit of a pipeline, a stage
Base factory interface for use with Guice assisted inject factories.
Used for constructing
Stage instances
The arguments here represent the set of dependencies provide by the pipelines framework.Something for stages to write messages to
Pipeline Stage validator.
Class throws exception in each methods just to inform customers that it was removed and he can use different client
Marker interface to indicate a Stage has side-effects