Provides a skeletal implementation of the
Etiao runtime implementation of the
Executes and provides runtime services to the executable graph
elements (oplets and functions).
|Invocation<T extends Oplet<I,O>,I,O>
invocation in the context of the
Context information for the
Oplet's execution context.
A forwarding Streamer whose destination
can be changed.
Tracks threads created for executing user tasks.
ScheduledThreadPoolExecutor with the ability to track
scheduled tasks and cancel them in case a task completes abruptly due to
Package org.apache.edgent.runtime.etiao Description
A runtime for executing an Edgent streaming topology, designed as an embeddable library
so that it can be executed in a simple Java application.
"EveryThing Is An Oplet" (ETIAO)
The runtime's focus is on executing oplets and their connected streams, where each
oplet is just a black box. Specifically this means that functionality is added by the introduction
of oplets into the graph that were not explicitly declared by the application developer.
For example, metrics are implemented by oplets, not the runtime. A metric collector is an
oplet that calculates metrics on tuples accepted on its input port, and them makes them
available, for example through JMX.