Class CoreMotorDispenser<D>

java.lang.Object

io.nosqlbench.engine.api.activityimpl.motor.CoreMotorDispenser<D>

All Implemented Interfaces:

MotorDispenser<D>

public class CoreMotorDispenser<D>
extends Object
implements MotorDispenser<D>

Produce index ActivityMotor instances with an input and action, given the input and an action factory.

Constructor Summary

Constructors

Constructor	Description
CoreMotorDispenser(Activity activity, InputDispenser inputDispenser, ActionDispenser actionDispenser, OutputDispenser outputDispenser)

Method Summary

Modifier and Type	Method	Description
Motor<D>	getMotor(ActivityDef activityDef, int slotId)	Resolve (find or create) a Motor instance for the slot specified.

Methods inherited from class java.lang.Object

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

Constructor Details

CoreMotorDispenser

public CoreMotorDispenser(Activity activity,
 InputDispenser inputDispenser,
 ActionDispenser actionDispenser,
 OutputDispenser outputDispenser)

Method Details

getMotor

public Motor<D> getMotor(ActivityDef activityDef,
 int slotId)

Description copied from interface: MotorDispenser

Resolve (find or create) a Motor instance for the slot specified. The motor is not required to be per-slot (per-thread), but any shared inputs motors be thread safe.

Specified by:

getMotor in interface MotorDispenser<D>

Parameters:

activityDef - the ActivityDef which will be used to parameterize the returned motor

slotId - The numbered slot within the activity instance for this motor

Returns:

A new or cached Motor for the specified slot.