fr.liglab.adele.cilia.framework

Class AbstractCorrelationScheduler

java.lang.Object

fr.liglab.adele.cilia.framework.AbstractScheduler

fr.liglab.adele.cilia.framework.AbstractCorrelationScheduler

All Implemented Interfaces:

IScheduler

Direct Known Subclasses:

CorrelationScheduler, CounterScheduler

public abstract class AbstractCorrelationScheduler
extends AbstractScheduler

Author:

Cilia Project Team

Field Summary

Fields

Modifier and Type	Field and Description
protected String	correlation Correlation expression to says which incoming messages belongs together.
protected static String	CORRELATION_DEFAULT Correlation expression by default.
protected CiliaExpression	expreParser

Fields inherited from class fr.liglab.adele.cilia.framework.AbstractScheduler

appLogger

Constructor Summary

Constructors

Constructor and Description
AbstractCorrelationScheduler(org.osgi.framework.BundleContext bcontext)

Method Summary

Methods

Modifier and Type	Method and Description
abstract boolean	checkCompletness(List dataset)
String	getCorrelationKey(Data data)
void	notifyData(Data data)
void	setCorrelation(String corre)

Methods inherited from class fr.liglab.adele.cilia.framework.AbstractScheduler

fireEvent, getData, getSourcesIds, init, process, setConnectedScheduler

Methods inherited from class java.lang.Object

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

Field Detail

correlation

protected String correlation

Correlation expression to says which incoming messages belongs together.

CORRELATION_DEFAULT

protected static final String CORRELATION_DEFAULT

Correlation expression by default.

See Also:

Constant Field Values

expreParser

protected CiliaExpression expreParser

Constructor Detail

AbstractCorrelationScheduler

public AbstractCorrelationScheduler(org.osgi.framework.BundleContext bcontext)

Method Detail

setCorrelation

public void setCorrelation(String corre)

notifyData

public void notifyData(Data data)

Specified by:

notifyData in interface IScheduler

Specified by:

notifyData in class AbstractScheduler

Parameters:

data - notified data.

getCorrelationKey

public String getCorrelationKey(Data data)

Parameters:

data -

Returns:

checkCompletness

public abstract boolean checkCompletness(List dataset)

Parameters:

dataset -

Returns: