Class FilteringInputDispenser

java.lang.Object

io.nosqlbench.engine.api.activityimpl.FilteringInputDispenser

All Implemented Interfaces:

InputDispenser

public class FilteringInputDispenser
extends Object
implements InputDispenser

Constructor Summary

Constructors

Constructor	Description
FilteringInputDispenser(InputDispenser dispenser, Predicate<ResultReadable> resultValuePredicate)

Method Summary

Modifier and Type	Method	Description
Input	getInput(long slot)	Resolve (find or create) an Input 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

FilteringInputDispenser

public FilteringInputDispenser(InputDispenser dispenser,
 Predicate<ResultReadable> resultValuePredicate)

Method Details

getInput

public Input getInput(long slot)

Description copied from interface: InputDispenser

Resolve (find or create) an Input instance for the slot specified. The input is not required to be per-slot (per-thread), but any shared inputs must be thread safe.

Specified by:

getInput in interface InputDispenser

Parameters:

slot - The numbered slot within the activity instance for this action.

Returns:

A new or cached Input for the specified slot.