Class FederationEvaluationStrategyFactory

java.lang.Object

org.eclipse.rdf4j.query.algebra.evaluation.impl.AbstractEvaluationStrategyFactory

org.eclipse.rdf4j.query.algebra.evaluation.impl.StrictEvaluationStrategyFactory

org.eclipse.rdf4j.federated.evaluation.FederationEvaluationStrategyFactory

All Implemented Interfaces:

EvaluationStrategyFactory, FederatedServiceResolverClient

public class FederationEvaluationStrategyFactory
extends StrictEvaluationStrategyFactory

Factory class for retrieving the FederationEvaluationStrategy to be used.

Customized strategies can be supplied to the federation using FedXFactory.withFederationEvaluationStrategyFactory(FederationEvaluationStrategyFactory)

Author:

Andreas Schwarte

Field Summary

Fields inherited from class StrictEvaluationStrategyFactory

collectionFactorySupplier

Modifier and Type	Field	Description
protected Supplier<CollectionFactory>	collectionFactorySupplier	Deprecated, for removal: This API element is subject to removal in a future version.

Constructor Summary

Constructors

Constructor	Description
FederationEvaluationStrategyFactory()

Method Summary

Modifier and Type	Method	Description
FederationEvaluationStrategy	createEvaluationStrategy(Dataset dataset, TripleSource tripleSource, EvaluationStatistics evaluationStatistics)	Create the FederationEvaluationStrategy to be used.
FederationContext	getFederationContext()
FederationManager.FederationType	getFederationType()
void	setFederationContext(FederationContext federationContext)
void	setFederationType(FederationManager.FederationType federationType)

Methods inherited from class StrictEvaluationStrategyFactory

getFederatedServiceResolver, setCollectionFactory, setFederatedServiceResolver

Modifier and Type	Method	Description
FederatedServiceResolver	getFederatedServiceResolver()	Deprecated, for removal: This API element is subject to removal in a future version. Gets the FederatedServiceResolver used by this client.
void	setCollectionFactory(Supplier<CollectionFactory> collectionFactory)	Deprecated, for removal: This API element is subject to removal in a future version. Set the collection factory to use.
void	setFederatedServiceResolver(FederatedServiceResolver resolver)	Deprecated, for removal: This API element is subject to removal in a future version. Sets the FederatedServiceResolver to use for this client.

Methods inherited from class AbstractEvaluationStrategyFactory

getOptimizerPipeline, getQuerySolutionCacheThreshold, isTrackResultSize, setOptimizerPipeline, setQuerySolutionCacheThreshold, setTrackResultSize

Modifier and Type	Method	Description
Optional<QueryOptimizerPipeline>	getOptimizerPipeline()	Get the QueryOptimizerPipeline that this factory will inject into the EvaluationStrategy, if any.
long	getQuerySolutionCacheThreshold()	Get the number of query solutions the EvaluationStrategy will keep in main memory before it attempts to sync to a temporary disk cache.
boolean	isTrackResultSize()	Returns the status of the result size tracking for the query plan.
void	setOptimizerPipeline(QueryOptimizerPipeline pipeline)	Set a QueryOptimizerPipeline to be used for query execution planning by the EvaluationStrategy.
void	setQuerySolutionCacheThreshold(long threshold)	Set the number of query solutions the EvaluationStrategy will keep in main memory before it attempts to sync to a temporary disk cache.
void	setTrackResultSize(boolean trackResultSize)	Enable or disable results size tracking for the query plan.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FederationEvaluationStrategyFactory

public FederationEvaluationStrategyFactory()

Method Details

getFederationType

public FederationManager.FederationType getFederationType()

setFederationType

public void setFederationType(FederationManager.FederationType federationType)

getFederationContext

public FederationContext getFederationContext()

setFederationContext

public void setFederationContext(FederationContext federationContext)

createEvaluationStrategy

public FederationEvaluationStrategy createEvaluationStrategy(Dataset dataset,
 TripleSource tripleSource,
 EvaluationStatistics evaluationStatistics)

Create the FederationEvaluationStrategy to be used. Note: all parameters may be null

Specified by:

createEvaluationStrategy in interface EvaluationStrategyFactory

Overrides:

createEvaluationStrategy in class StrictEvaluationStrategyFactory

Parameters:

dataset - the DataSet to evaluate queries against.

tripleSource - the TripleSource to evaluate queries against.

evaluationStatistics - the store evaluation statistics to use for query optimization.

Returns:

an EvaluationStrategy.