org.rifidi.edge.tools.diagnostics

Class Exposure

java.lang.Object

java.util.Dictionary<K,V>

java.util.Hashtable<java.lang.Object,java.lang.Object>

java.util.Properties

org.rifidi.edge.tools.diagnostics.Exposure

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.Map<java.lang.Object,java.lang.Object>

Direct Known Subclasses:

DelayExposure, RateExposure

public abstract class Exposure
extends java.util.Properties

An exposure defines how tags from the TagSet are put into esper as events.

Author:

Kyle Neumeier - kyle@pramari.com

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	EXPOSURE_TYPE_DELAY A delay Exposure type - 'delay'
static java.lang.String	EXPOSURE_TYPE_RATE A rate exposure type - 'rate'
static java.lang.String	PROPERTY_RANDOM Whether or not tags should be selected from the tag set at random - 'random'
static java.lang.String	PROPERTY_STOPCOUNT A trigger to stop the runner based on the number of tags sent to esper 'stop.count'
static java.lang.String	PROPERTY_STOPTIMER A trigger to stop the runner based on a timer - 'stop.timer'
static java.lang.String	PROPERTY_TYPE The type of exposure

Constructor Summary

Constructors

Constructor and Description
Exposure(java.util.Properties defaults)

Method Summary

Modifier and Type	Method and Description
abstract ExposureRunner<?>	createRunner(java.util.List<AbstractReadData<?>> tags, com.espertech.esper.client.EPRuntime runtime) Create a concrete runner for this Exposure
java.lang.String	getExposureType() Get the type of this exposure
boolean	getRandom() Whether or not this exposure selects from the tag list at random
int	getTagCountStopTrigger() Get the number of tags we should send to esper before stopping.
long	getTimerStopTrigger() Get the length of time this runner should run until it stops

Methods inherited from class java.util.Properties

getProperty, getProperty, list, list, load, load, loadFromXML, propertyNames, save, setProperty, store, store, storeToXML, storeToXML, stringPropertyNames

Methods inherited from class java.util.Hashtable

clear, clone, compute, computeIfAbsent, computeIfPresent, contains, containsKey, containsValue, elements, entrySet, equals, forEach, get, getOrDefault, hashCode, isEmpty, keys, keySet, merge, put, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, toString, values

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

PROPERTY_TYPE

public static final java.lang.String PROPERTY_TYPE

The type of exposure

See Also:

Constant Field Values

EXPOSURE_TYPE_DELAY

public static final java.lang.String EXPOSURE_TYPE_DELAY

A delay Exposure type - 'delay'

See Also:

Constant Field Values

EXPOSURE_TYPE_RATE

public static final java.lang.String EXPOSURE_TYPE_RATE

A rate exposure type - 'rate'

See Also:

Constant Field Values

PROPERTY_STOPCOUNT

public static final java.lang.String PROPERTY_STOPCOUNT

A trigger to stop the runner based on the number of tags sent to esper 'stop.count'

See Also:

Constant Field Values

PROPERTY_STOPTIMER

public static final java.lang.String PROPERTY_STOPTIMER

A trigger to stop the runner based on a timer - 'stop.timer'

See Also:

Constant Field Values

PROPERTY_RANDOM

public static final java.lang.String PROPERTY_RANDOM

Whether or not tags should be selected from the tag set at random - 'random'

See Also:

Constant Field Values

Constructor Detail

Exposure

public Exposure(java.util.Properties defaults)

Parameters:

defaults -

Method Detail

getExposureType

public java.lang.String getExposureType()

Get the type of this exposure

Returns:

getTagCountStopTrigger

public int getTagCountStopTrigger()

Get the number of tags we should send to esper before stopping.

Returns:

getTimerStopTrigger

public long getTimerStopTrigger()

Get the length of time this runner should run until it stops

Returns:

getRandom

public boolean getRandom()

Whether or not this exposure selects from the tag list at random

Returns:

createRunner

public abstract ExposureRunner<?> createRunner(java.util.List<AbstractReadData<?>> tags,
                                               com.espertech.esper.client.EPRuntime runtime)

Create a concrete runner for this Exposure

Parameters:

tags -

runtime -

Returns: