|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.eql.db.PollingViewable
public class PollingViewable
Implements a poller viewable that uses a polling strategy, a cache and some input parameters extracted from event streams to perform the polling.
Constructor Summary | |
---|---|
PollingViewable(int myStreamNumber,
List<String> inputParameters,
PollExecStrategy pollExecStrategy,
DataCache dataCache,
EventType eventType)
Ctor. |
Method Summary | |
---|---|
View |
addView(View view)
Add a view to the viewable object. |
EventType |
getEventType()
Provides metadata information about the type of object the event collection contains. |
List<View> |
getViews()
Returns all added views. |
boolean |
hasViews()
Test is there are any views to the Viewable. |
Iterator<EventBean> |
iterator()
Allows iteration through all elements in this event collection. |
List<EventBean>[] |
poll(EventBean[][] lookupEventsPerStream)
Poll for stored historical or reference data using events per stream and returing for each event-per-stream row a separate list with events representing the poll result. |
boolean |
removeView(View view)
Remove a view. |
void |
stop()
Stops the underlying resources. |
void |
validate(StreamTypeService streamTypeService)
Validate the view. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PollingViewable(int myStreamNumber, List<String> inputParameters, PollExecStrategy pollExecStrategy, DataCache dataCache, EventType eventType)
myStreamNumber
- is the stream number of the viewinputParameters
- are the event property names providing input parameter keyspollExecStrategy
- is the strategy to use for retrieving resultsdataCache
- is looked up before using the strategyeventType
- is the type of events generated by the viewMethod Detail |
---|
public void stop()
StopCallback
stop
in interface StopCallback
public void validate(StreamTypeService streamTypeService) throws ExprValidationException
ValidatedView
validate
in interface ValidatedView
streamTypeService
- supplies the types of streams against which to validate
ExprValidationException
- is thrown to indicate an exception in validating the viewpublic List<EventBean>[] poll(EventBean[][] lookupEventsPerStream)
HistoricalEventViewable
poll
in interface HistoricalEventViewable
lookupEventsPerStream
- is the events per stream where the
first dimension is a number of rows (often 1 depending on windows used) and
the second dimension is the number of streams participating in a join.
public View addView(View view)
Viewable
addView
in interface Viewable
view
- to add
public List<View> getViews()
Viewable
getViews
in interface Viewable
public boolean removeView(View view)
Viewable
removeView
in interface Viewable
view
- to remove
public boolean hasViews()
Viewable
hasViews
in interface Viewable
public EventType getEventType()
EventCollection
getEventType
in interface EventCollection
public Iterator<EventBean> iterator()
EventCollection
iterator
in interface Iterable<EventBean>
iterator
in interface EventCollection
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |