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

Class FlushedEventBuffer

java.lang.Object

com.espertech.esper.common.internal.event.core.FlushedEventBuffer

public class FlushedEventBuffer
extends Object

Buffer for events - accumulates events until flushed.

Constructor Summary

Constructors

Constructor	Description
FlushedEventBuffer()

Method Summary

Modifier and Type	Method	Description
void	add(EventBean[] events)	Add an event array to buffer.
void	flush()	Empty buffer.
EventBean[]	getAndFlush()	Get the events currently buffered.

Methods inherited from class java.lang.Object

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

Constructor Details

FlushedEventBuffer

public FlushedEventBuffer()

Method Details

add

public void add(EventBean[] events)

Add an event array to buffer.

Parameters:

events - to add

getAndFlush

public EventBean[] getAndFlush()

Get the events currently buffered. Returns null if the buffer is empty. Flushes the buffer.

Returns:

array of events in buffer or null if empty

flush

public void flush()

Empty buffer.