com.espertech.esper.runtime.internal.subscriber

Class ResultDeliveryStrategyObjectArr

java.lang.Object

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

All Implemented Interfaces:

ResultDeliveryStrategy

Direct Known Subclasses:

ResultDeliveryStrategyObjectArrWStmt

public class ResultDeliveryStrategyObjectArr
extends Object
implements ResultDeliveryStrategy

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

Field Summary

Fields

Modifier and Type	Field and Description
protected Method	method
protected EPStatement	statement
protected Object	subscriber

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected Object[][]	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 Detail

statement

protected final EPStatement statement

subscriber

protected final Object subscriber

method

protected final Method method

Constructor Detail

ResultDeliveryStrategyObjectArr

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

Ctor.

Parameters:

subscriber - is the subscriber to deliver to

method - the method to invoke

statement - statement

classpathImportService - runtime imports

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

Parameters:

result - is the insert and remove stream to indicate

convert

protected Object[][] convert(com.espertech.esper.common.client.EventBean[] events)