com.espertech.esper.runtime.internal.subscriber

Class ResultDeliveryStrategyObjectArrWStmt

java.lang.Object

com.espertech.esper.runtime.internal.subscriber.ResultDeliveryStrategyObjectArr

com.espertech.esper.runtime.internal.subscriber.ResultDeliveryStrategyObjectArrWStmt

All Implemented Interfaces:

ResultDeliveryStrategy

public class ResultDeliveryStrategyObjectArrWStmt
extends ResultDeliveryStrategyObjectArr

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

Field Summary

Fields inherited from class com.espertech.esper.runtime.internal.subscriber.ResultDeliveryStrategyObjectArr

method, statement, subscriber

Constructor Summary

Constructors

Constructor and Description
ResultDeliveryStrategyObjectArrWStmt(EPStatement statement, Object subscriber, Method method, com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)

Method Summary

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

Methods inherited from class com.espertech.esper.runtime.internal.subscriber.ResultDeliveryStrategyObjectArr

convert

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultDeliveryStrategyObjectArrWStmt

public ResultDeliveryStrategyObjectArrWStmt(EPStatement statement,
                                            Object subscriber,
                                            Method method,
                                            com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)

Method Detail

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

Overrides:

execute in class ResultDeliveryStrategyObjectArr

Parameters:

result - is the insert and remove stream to indicate