com.espertech.esper.common.internal.epl.historical.indexingstrategy

Class PollResultIndexingStrategyComposite

java.lang.Object

com.espertech.esper.common.internal.epl.historical.indexingstrategy.PollResultIndexingStrategyComposite

All Implemented Interfaces:

PollResultIndexingStrategy

public class PollResultIndexingStrategyComposite
extends Object
implements PollResultIndexingStrategy

Constructor Summary

Constructors

Constructor and Description
PollResultIndexingStrategyComposite()

Method Summary

Modifier and Type	Method and Description
EventTable[]	index(List<EventBean> pollResult, boolean isActiveCache, AgentInstanceContext agentInstanceContext) Build and index of a poll result.
void	init()
void	setFactory(PropertyCompositeEventTableFactory factory)
void	setHashGetter(EventPropertyValueGetter hashGetter)
void	setOptionalKeyedProps(String[] optionalKeyedProps)
void	setOptKeyCoercedTypes(Class[] optKeyCoercedTypes)
void	setOptRangeCoercedTypes(Class[] optRangeCoercedTypes)
void	setRangeGetters(EventPropertyValueGetter[] rangeGetters)
void	setRangeProps(String[] rangeProps)
void	setStreamNum(int streamNum)

Methods inherited from class java.lang.Object

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

Constructor Detail

PollResultIndexingStrategyComposite

public PollResultIndexingStrategyComposite()

Method Detail

index

public EventTable[] index(List<EventBean> pollResult,
                          boolean isActiveCache,
                          AgentInstanceContext agentInstanceContext)

Description copied from interface: PollResultIndexingStrategy

Build and index of a poll result.

Specified by:

index in interface PollResultIndexingStrategy

Parameters:

pollResult - result of a poll operation

isActiveCache - true to indicate that caching is active and therefore index building makes sense as the index structure is not a throw-away.

agentInstanceContext - statement context

Returns:

indexed collection of poll results

init

public void init()

setStreamNum

public void setStreamNum(int streamNum)

setOptionalKeyedProps

public void setOptionalKeyedProps(String[] optionalKeyedProps)

setOptKeyCoercedTypes

public void setOptKeyCoercedTypes(Class[] optKeyCoercedTypes)

setHashGetter

public void setHashGetter(EventPropertyValueGetter hashGetter)

setRangeProps

public void setRangeProps(String[] rangeProps)

setOptRangeCoercedTypes

public void setOptRangeCoercedTypes(Class[] optRangeCoercedTypes)

setRangeGetters

public void setRangeGetters(EventPropertyValueGetter[] rangeGetters)

setFactory

public void setFactory(PropertyCompositeEventTableFactory factory)