net.sf.sparql.benchmarking.operations.update.callables
Class AbstractInMemoryUpdateCallable<T extends Options>

java.lang.Object
  extended by net.sf.sparql.benchmarking.operations.AbstractOperationCallable<T>
      extended by net.sf.sparql.benchmarking.operations.update.callables.AbstractUpdateCallable<T>
          extended by net.sf.sparql.benchmarking.operations.update.callables.AbstractInMemoryUpdateCallable<T>
Type Parameters:
T - Options type
All Implemented Interfaces:
Callable<OperationRun>, OperationCallable<T>
Direct Known Subclasses:
InMemoryUpdateCallable

public abstract class AbstractInMemoryUpdateCallable<T extends Options>
extends AbstractUpdateCallable<T>

Abstract callable for operations that run updates against a local in-memory dataset

Author:
rvesse

Constructor Summary
AbstractInMemoryUpdateCallable(Runner<T> runner, T options)
          Creates a new callable
 
Method Summary
protected  UpdateProcessor createUpdateProcessor(UpdateRequest update)
          Creates an update processor for running the update
protected  GraphStore getGraphStore(T options)
          Gets the graph store to run the query against
 
Methods inherited from class net.sf.sparql.benchmarking.operations.update.callables.AbstractUpdateCallable
call, customizeRequest, getUpdate
 
Methods inherited from class net.sf.sparql.benchmarking.operations.AbstractOperationCallable
cancel, getOptions, getRunner, isCancelled
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractInMemoryUpdateCallable

public AbstractInMemoryUpdateCallable(Runner<T> runner,
                                      T options)
Creates a new callable

Parameters:
runner - Runner
options - Options
Method Detail

getGraphStore

protected GraphStore getGraphStore(T options)
Gets the graph store to run the query against

By default all in-memory based operations simply expect a non-null dataset to be available via the Options.getDataset() method. This is converted to a GraphStore by calling the standard ARQ GraphStoreFactory.create(Dataset) method.

Returns:
Graph store

createUpdateProcessor

protected UpdateProcessor createUpdateProcessor(UpdateRequest update)
Description copied from class: AbstractUpdateCallable
Creates an update processor for running the update

Specified by:
createUpdateProcessor in class AbstractUpdateCallable<T extends Options>
Parameters:
update - Update
Returns:
Update processor


Copyright © 2014. All Rights Reserved.