CachingFederationStrategy provided by the catalog-core-standardframework bundle.@Deprecated public class FifoFederationStrategy extends Object implements FederationStrategy
FifoFederationStrategy represents a First In First Out (FIFO) federation
strategy that returns results in the order they are received. This means that the first results
received by this strategy are the first results sent back to the client.| Constructor and Description |
|---|
FifoFederationStrategy(ExecutorService queryExecutorService,
List<PreFederatedQueryPlugin> preQuery,
List<PostFederatedQueryPlugin> postQuery)
Deprecated.
Instantiates a
FifoFederationStrategy with the provided ExecutorService. |
| Modifier and Type | Method and Description |
|---|---|
protected QueryResponse |
executePostFederationPlugins(QueryResponse queryResponse)
Deprecated.
|
protected void |
executeSourceQueries(List<Source> sources,
Map<Source,Future<SourceResponse>> futures,
QueryRequest modifiedQueryRequest)
Deprecated.
|
QueryResponse |
federate(List<Source> sources,
QueryRequest queryRequest)
Deprecated.
Federate the given query to the
List of Sources, returning a QueryResponse back to the user that will include the matching Results. |
protected Query |
getModifiedQuery(Query originalQuery,
int numberOfSources,
int offset,
int pageSize)
Deprecated.
|
public FifoFederationStrategy(ExecutorService queryExecutorService, List<PreFederatedQueryPlugin> preQuery, List<PostFederatedQueryPlugin> postQuery)
FifoFederationStrategy with the provided ExecutorService.queryExecutorService - the ExecutorService for queriespublic QueryResponse federate(List<Source> sources, QueryRequest queryRequest)
FederationStrategyList of Sources, returning a QueryResponse back to the user that will include the matching Results.federate in interface FederationStrategysources - the List of Sources to be queried. Cannot be null or
empty.queryRequest - the QueryRequest to execute. Cannot be null.QueryResponse which contains the list of Results.protected QueryResponse executePostFederationPlugins(QueryResponse queryResponse)
protected void executeSourceQueries(List<Source> sources, Map<Source,Future<SourceResponse>> futures, QueryRequest modifiedQueryRequest)
This work is licensed under a Creative Commons Attribution 4.0 International License.