com.espertech.esper.epl.join.pollindex

Class PollResultIndexingStrategyIndexCoerce

java.lang.Object

com.espertech.esper.epl.join.pollindex.PollResultIndexingStrategyIndexCoerce

All Implemented Interfaces:

PollResultIndexingStrategy

public class PollResultIndexingStrategyIndexCoerce
extends java.lang.Object
implements PollResultIndexingStrategy

Strategy for building an index out of poll-results knowing the properties to base the index on, and their coercion types.

Constructor Summary

Constructors

Constructor and Description
PollResultIndexingStrategyIndexCoerce(int streamNum, EventType eventType, java.lang.String[] propertyNames, java.lang.Class[] coercionTypes) Ctor.

Method Summary

Modifier and Type	Method and Description
EventTable[]	index(java.util.List<EventBean> pollResult, boolean isActiveCache, StatementContext statementContext) Build and index of a poll result.
java.lang.String	toQueryPlan()

Methods inherited from class java.lang.Object

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

Constructor Detail

PollResultIndexingStrategyIndexCoerce

public PollResultIndexingStrategyIndexCoerce(int streamNum,
                                             EventType eventType,
                                             java.lang.String[] propertyNames,
                                             java.lang.Class[] coercionTypes)

Ctor.

Parameters:

streamNum - is the stream number of the indexed stream

eventType - is the event type of the indexed stream

propertyNames - is the property names to be indexed

coercionTypes - is the types to coerce to for keys and values

Method Detail

index

public EventTable[] index(java.util.List<EventBean> pollResult,
                          boolean isActiveCache,
                          StatementContext statementContext)

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.

statementContext - statement context

Returns:

indexed collection of poll results

toQueryPlan

public java.lang.String toQueryPlan()

Specified by:

toQueryPlan in interface PollResultIndexingStrategy