|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.core.MethodPollingViewable
public class MethodPollingViewable
Polling-data provider that calls a static method on a class and passed parameters, and wraps the results as POJO events.
Constructor Summary | |
---|---|
MethodPollingViewable(MethodStreamSpec methodStreamSpec,
int myStreamNumber,
List<ExprNode> 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. |
EventTable[] |
poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy)
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,
MethodResolutionService methodResolutionService,
TimeProvider timeProvider,
VariableService variableService)
Validate the view. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MethodPollingViewable(MethodStreamSpec methodStreamSpec, int myStreamNumber, List<ExprNode> inputParameters, PollExecStrategy pollExecStrategy, DataCache dataCache, EventType eventType)
methodStreamSpec
- defines class and method namesmyStreamNumber
- is the stream numberinputParameters
- the input parameter expressionspollExecStrategy
- the execution strategydataCache
- the cache to useeventType
- the type of event returnedMethod Detail |
---|
public void stop()
StopCallback
stop
in interface StopCallback
public void validate(StreamTypeService streamTypeService, MethodResolutionService methodResolutionService, TimeProvider timeProvider, VariableService variableService) throws ExprValidationException
ValidatedView
validate
in interface ValidatedView
streamTypeService
- supplies the types of streams against which to validatemethodResolutionService
- for resolving imports and classes and methodstimeProvider
- for providing current timevariableService
- for access to variables
ExprValidationException
- is thrown to indicate an exception in validating the viewpublic EventTable[] poll(EventBean[][] lookupEventsPerStream, PollResultIndexingStrategy indexingStrategy)
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.indexingStrategy
- the strategy to use for converting poll results into a indexed table for fast lookup
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 EventCollection
iterator
in interface Iterable<EventBean>
|
© 2007 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |