com.bigdata.rdf.sparql.ast.service

Class RemoteServiceCallImpl

java.lang.Object

com.bigdata.rdf.sparql.ast.service.RemoteServiceCallImpl

All Implemented Interfaces:

RemoteServiceCall, ServiceCall<org.openrdf.query.BindingSet>

public class RemoteServiceCallImpl
extends Object
implements RemoteServiceCall

This class handles vectored remote service invocation by generating an appropriate SPARQL query (with BINDINGS) and an appropriate HTTP request. The behavior of this class may be configured in the ServiceRegistry by adjusting the RemoteServiceOptions for the service URI.

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
RemoteServiceCallImpl(ServiceCallCreateParams params)

Method Summary

Methods

Modifier and Type	Method and Description
ICloseableIterator<org.openrdf.query.BindingSet>	call(org.openrdf.query.BindingSet[] bindingSets) Invoke an service.
RemoteServiceOptions	getServiceOptions() Return options and metadata for the service end point.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteServiceCallImpl

public RemoteServiceCallImpl(ServiceCallCreateParams params)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getServiceOptions

public RemoteServiceOptions getServiceOptions()

Description copied from interface: ServiceCall

Return options and metadata for the service end point. TODO The options for a ServiceCall instance are shared with all instances for the same factory. This should be appropriate because the factory is specific to the service URI. The only exception would be the ServiceRegistry.getDefaultServiceFactory(). Consider replacing this with a back reference to the ServiceFactory.

Specified by:

getServiceOptions in interface ServiceCall<org.openrdf.query.BindingSet>

call

public ICloseableIterator<org.openrdf.query.BindingSet> call(org.openrdf.query.BindingSet[] bindingSets)
                                                      throws Exception

Description copied from interface: ServiceCall

Invoke an service. The caller will join the results from the service with the solutions in the context in which the service was invoked (using a solution set hash join pattern).

Specified by:

call in interface ServiceCall<org.openrdf.query.BindingSet>

Parameters:

bindingSets - The binding sets flowing into the service.

Returns:

An iterator from which the solutions can be drained. If the iterator is closed, the service invocation must be cancelled.

Throws:

Exception - TODO RECHUNKING: This should probably return an ICloseableIterator for consistent chunking across our access path abstractions. And maybe it could implement IBindingSetAccessPath.