Package com.espertech.esper.runtime.internal.subscriber

Class ResultDeliveryStrategyMap

java.lang.Object

com.espertech.esper.runtime.internal.subscriber.ResultDeliveryStrategyMap

All Implemented Interfaces:

ResultDeliveryStrategy

Direct Known Subclasses:

ResultDeliveryStrategyMapWStmt

public class ResultDeliveryStrategyMap
extends Object
implements ResultDeliveryStrategy

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final String[]	columnNames
protected final Method	method
protected final EPStatement	statement
protected final Object	subscriber

Constructor Summary

Constructors

Constructor	Description
ResultDeliveryStrategyMap(EPStatement statement, Object subscriber, Method method, String[] columnNames, com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)	Ctor.

Method Summary

Modifier and Type	Method	Description
protected Map[]	convert(com.espertech.esper.common.client.EventBean[] events)
void	execute(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> result)	Execute the dispatch.

Methods inherited from class java.lang.Object

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

Field Details

statement

protected final EPStatement statement

subscriber

protected final Object subscriber

method

protected final Method method

columnNames

protected final String[] columnNames

Constructor Details

ResultDeliveryStrategyMap

public ResultDeliveryStrategyMap(EPStatement statement,
 Object subscriber,
 Method method,
 String[] columnNames,
 com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)

Ctor.

Parameters:

subscriber - the object to deliver to

method - the delivery method

columnNames - the column names for the map

statement - statement

classpathImportService - runtime imports

Method Details

execute

public void execute(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.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 Map[] convert(com.espertech.esper.common.client.EventBean[] events)