Module org.apache.jena.arq

Package org.apache.jena.sparql.service

Class ServiceExecutorRegistry

java.lang.Object

org.apache.jena.sparql.service.ServiceExecutorRegistry

public class ServiceExecutorRegistry
extends Object

Registry for service executors that can be extended with custom ones. Bulk and single (=non-bulk) executors are maintained in two separate lists. Default execution will always start with the bulk list first. Once that list is exhausted by means of all bulk executors having delegated the request, then the non-bulk ones will be considered. There is no need to explicitly register a bulk-to-non-bulk bridge.

Field Summary

Fields

Modifier and Type	Field	Description
static ServiceExecutor	httpService	A "call with SPARQL query" service executor.

Constructor Summary

Constructors

Constructor	Description
ServiceExecutorRegistry()

Method Summary

Modifier and Type	Method	Description
ServiceExecutorRegistry	add(ServiceExecutor f)	Wraps the given service executor as a chaining one and prepends it to the non-bulk chain via addSingleLink(ChainingServiceExecutor)
ServiceExecutorRegistry	addBulkLink(ChainingServiceExecutorBulk f)	Add a chaining bulk executor as a link to the executor chain
ServiceExecutorRegistry	addSingleLink(ChainingServiceExecutor f)	Prepend the given service executor as a link to the per-binding chain
static ServiceExecutorRegistry	chooseRegistry(Context context)	Return the registry from the given context if present; otherwise return the global one
ServiceExecutorRegistry	copy()	Create an independent copy of the registry
ServiceExecutorRegistry	copyFrom(Context cxt)	Return a copy of the registry in the context (if present) or a fresh instance
static ServiceExecutorRegistry	createFrom(ServiceExecutorRegistry from)	Copies the origin registry into a new one, or makes a fresh instance if the specified registry is null.
static QueryIterator	exec(QueryIterator input, OpService opService, ExecutionContext execCxt)	Deprecated. To be removed.
static ServiceExecutorRegistry	get()	Return the global instance from the ARQ context; create that instance if needed.
static ServiceExecutorRegistry	get(Context context)	Return the registry from the given context only; null if there is none
List<ChainingServiceExecutorBulk>	getBulkChain()	Retrieve the actual list of bulk executors; allows for re-ordering
List<ChainingServiceExecutor>	getSingleChain()	Retrieve the actual list of per-binding executors; allows for re-ordering
static void	init()
static void	initWithDefaults(ServiceExecutorRegistry registry)	Blindly adds the default executor(s); concretely adds the http executor
ServiceExecutorRegistry	remove(ServiceExecutor f)	Remove a given service executor - internally attempts to unwrap every chaining service executor
ServiceExecutorRegistry	removeBulkLink(ChainingServiceExecutorBulk f)	Remove the given service executor
ServiceExecutorRegistry	removeSingleLink(ChainingServiceExecutor f)	Remove the given service executor from the per-binding chain
static void	set(Context context, ServiceExecutorRegistry reg)
static ServiceExecutorRegistry	standardRegistry()

Methods inherited from class java.lang.Object

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

Field Details

httpService

public static ServiceExecutor httpService

A "call with SPARQL query" service executor.

Constructor Details

ServiceExecutorRegistry

public ServiceExecutorRegistry()

Method Details

standardRegistry

public static ServiceExecutorRegistry standardRegistry()

initWithDefaults

public static void initWithDefaults(ServiceExecutorRegistry registry)

Blindly adds the default executor(s); concretely adds the http executor

init

public static void init()

get

public static ServiceExecutorRegistry get()

Return the global instance from the ARQ context; create that instance if needed. Never returns null.

chooseRegistry

public static ServiceExecutorRegistry chooseRegistry(Context context)

Return the registry from the given context if present; otherwise return the global one

get

public static ServiceExecutorRegistry get(Context context)

Return the registry from the given context only; null if there is none

set

public static void set(Context context,
 ServiceExecutorRegistry reg)

createFrom

public static ServiceExecutorRegistry createFrom(ServiceExecutorRegistry from)

Copies the origin registry into a new one, or makes a fresh instance if the specified registry is null.

Parameters:

from - ServiceExecutorRegistry or null

Returns:

ServiceExecutorRegistry a new instance

addSingleLink

public ServiceExecutorRegistry addSingleLink(ChainingServiceExecutor f)

Prepend the given service executor as a link to the per-binding chain

removeSingleLink

public ServiceExecutorRegistry removeSingleLink(ChainingServiceExecutor f)

Remove the given service executor from the per-binding chain

add

public ServiceExecutorRegistry add(ServiceExecutor f)

Wraps the given service executor as a chaining one and prepends it to the non-bulk chain via addSingleLink(ChainingServiceExecutor)

remove

public ServiceExecutorRegistry remove(ServiceExecutor f)

Remove a given service executor - internally attempts to unwrap every chaining service executor

getSingleChain

public List<ChainingServiceExecutor> getSingleChain()

Retrieve the actual list of per-binding executors; allows for re-ordering

addBulkLink

public ServiceExecutorRegistry addBulkLink(ChainingServiceExecutorBulk f)

Add a chaining bulk executor as a link to the executor chain

removeBulkLink

public ServiceExecutorRegistry removeBulkLink(ChainingServiceExecutorBulk f)

Remove the given service executor

getBulkChain

public List<ChainingServiceExecutorBulk> getBulkChain()

Retrieve the actual list of bulk executors; allows for re-ordering

copy

public ServiceExecutorRegistry copy()

Create an independent copy of the registry

copyFrom

public ServiceExecutorRegistry copyFrom(Context cxt)

Return a copy of the registry in the context (if present) or a fresh instance

exec

@Deprecated(since="4.9.0")
public static QueryIterator exec(QueryIterator input,
 OpService opService,
 ExecutionContext execCxt)

Deprecated.

To be removed. Moved to ServiceExec.exec(org.apache.jena.sparql.engine.QueryIterator, org.apache.jena.sparql.algebra.op.OpService, org.apache.jena.sparql.engine.ExecutionContext).

Execution