com.espertech.esper.core.service
Class ResultDeliveryStrategyMap

java.lang.Object
  com.espertech.esper.core.service.ResultDeliveryStrategyMap

All Implemented Interfaces:

ResultDeliveryStrategy

Direct Known Subclasses:

ResultDeliveryStrategyMapWStmt

public class ResultDeliveryStrategyMap
extends java.lang.Object
implements ResultDeliveryStrategy

A result delivery strategy that uses an "update" method that accepts a pair of map array.

Field Summary

protected java.lang.String[]	columnNames
protected net.sf.cglib.reflect.FastMethod	fastMethod
protected EPStatement	statement
protected java.lang.Object	subscriber

Constructor Summary

ResultDeliveryStrategyMap(EPStatement statement, java.lang.Object subscriber, java.lang.reflect.Method method, java.lang.String[] columnNames)
Ctor.

Method Summary

protected java.util.Map[]	convert(EventBean[] events)
void	execute(UniformPair<EventBean[]> result) Execute the dispatch.

Methods inherited from class java.lang.Object

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

Field Detail

statement

protected final EPStatement statement

subscriber

protected final java.lang.Object subscriber

fastMethod

protected final net.sf.cglib.reflect.FastMethod fastMethod

columnNames

protected final java.lang.String[] columnNames

Constructor Detail

ResultDeliveryStrategyMap

public ResultDeliveryStrategyMap(EPStatement statement,
                                 java.lang.Object subscriber,
                                 java.lang.reflect.Method method,
                                 java.lang.String[] columnNames)

Ctor.

Parameters:

subscriber - the object to deliver to

method - the delivery method

columnNames - the column names for the map

Method Detail

execute

public void execute(UniformPair<EventBean[]> result)

Description copied from interface: ResultDeliveryStrategy

Execute the dispatch.

Specified by:

execute in interface ResultDeliveryStrategy

Parameters:

result - is the insert and remove stream to indicate

convert

protected java.util.Map[] convert(EventBean[] events)