Package com.espertech.esper.common.internal.view.core

Class ZeroDepthStreamIterableWAudit

java.lang.Object

com.espertech.esper.common.internal.view.core.ZeroDepthStreamIterable

com.espertech.esper.common.internal.view.core.ZeroDepthStreamIterableWAudit

All Implemented Interfaces:

EventStream, Viewable, Iterable<EventBean>

public final class ZeroDepthStreamIterableWAudit
extends ZeroDepthStreamIterable

Event stream implementation that does not keep any window by itself of the events coming into the stream, however is itself iterable and keeps the last event.

Field Summary

Fields inherited from interface com.espertech.esper.common.internal.view.core.Viewable

EPTYPE

Constructor Summary

Constructors

Constructor	Description
ZeroDepthStreamIterableWAudit(EventType eventType, AgentInstanceContext agentInstanceContext, FilterSpecActivatable filterSpec, int streamNumber, boolean subselect, int subselectNumber)

Method Summary

Modifier and Type	Method	Description
void	insert(EventBean theEvent)	Insert a new event onto the stream.
void	insert(EventBean[] events)	Insert new events onto the stream.

Methods inherited from class com.espertech.esper.common.internal.view.core.ZeroDepthStreamIterable

getChild, getEventType, iterator, setChild

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

ZeroDepthStreamIterableWAudit

public ZeroDepthStreamIterableWAudit(EventType eventType,
 AgentInstanceContext agentInstanceContext,
 FilterSpecActivatable filterSpec,
 int streamNumber,
 boolean subselect,
 int subselectNumber)

Method Details

insert

public void insert(EventBean theEvent)

Description copied from interface: EventStream

Insert a new event onto the stream.

Specified by:

insert in interface EventStream

Overrides:

insert in class ZeroDepthStreamIterable

Parameters:

theEvent - to insert

insert

public void insert(EventBean[] events)

Description copied from interface: EventStream

Insert new events onto the stream.

Specified by:

insert in interface EventStream

Overrides:

insert in class ZeroDepthStreamIterable

Parameters:

events - to insert