Back to results
US 9,542,708 B2Granted
Event server using caching
AssigneeOracle International Corporation
InventorsAndrew Piper, Alexandre de Castro Alves, Seth White
Life of this patent
Estimating the term…
Abstract
An event server adapted to receive events from an input stream and produce an output event stream. The event server uses a processor using code in an event processing language to process the events. The event server obtaining input events from and/or producing output events to a cache.
Claims17
A system adapted to receive events from an input stream and produce an output event stream, the system comprising:
- a computer which includes a microprocessor;
- an event server including an event processor which executes on the computer,
- wherein the event processor uses an event processing language (EPL) code to process events,
- wherein the event server is implemented as part of an event processing network (EPN), and
- wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, and stream components and the event processor, which are used to process events;
- a cache registered as a sink and configured as a listener enabling the cache to receive events published to a stream by an event server application, and store the published events in the cache for use by a plurality of applications in the event server before asynchronously writing the published events to a secondary storage,
- wherein the EPN assembly file indicates deployment of the cache including whether the cache is local or distributed;
- a query processor for querying streams to pull data during query evaluation,
- wherein the cache appears to the query processor as a stream which can be queried to pull data;
- and
- an event type repository which registers the cache and a data type of data associated with the published events stored in the cache, and
- wherein upon registering the cache as a sink, the event type repository indicates that the event processor uses one or more input streams as sources of events.
9 more elements
A method of providing an event server adapted to receive events from an input stream and produce an output event stream, the method operating on one or more microprocessors and comprising:
- providing an event server as part of an event processing network (EPN),
- wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, and stream components and an event processor, which are used to process events;
- receiving events via the event processor, wherein the event processor uses an event processing language (EPL) code to process the events;
- determining, via an event type registry, that the EPL code requires a particular data type in processing the events;
- publishing events to an input stream via an event server application, wherein the published events are stored in a cache registered as a sink and configured as a listener for use by a plurality of applications in the event server, before asynchronously writing the published events to a secondary storage,
- wherein the EPN assembly file indicates deployment of the cache including whether the cache is local or distributed;
- querying streams, via a query processor, to pull data during query evaluation,
- wherein the cache appears to the query processor as a stream which can be queried to pull data;
- and
- providing an event type repository which registers the cache and a data type of data associated with the published events stored in the cache, and
- wherein upon registering the cache as a sink, the event type repository is configured to indicate that the event processor uses one or more input streams as sources of events.
8 more elements
A non-transitory computer readable storage medium including instructions stored thereon which when read by a computer cause the computer to perform the steps comprising:
- providing an event server as part of an event processing network (EPN),
- wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, and stream components and an event processor, which are used to process events;
- receiving events via the event processor, wherein the event processor uses an event processing language (EPL) code to process the events;
- determining, via an event type registry, that the EPL code requires a particular data type in processing the events;
- publishing events to an input stream via an event server application, wherein the published events are stored in a cache registered as a sink and configured listener for use by a plurality of applications in the event server, before asynchronously writing the published events to a secondary storage,
- wherein the EPN assembly file indicates deployment of the cache including whether the cache is local or distributed;
- querying streams, via a query processor, to pull data during query evaluation,
- wherein the cache appears to the query processor as a stream which can be queried to pull data;
- and
- providing an event type repository which registers the cache and a data type of data associated with the published events stored in the cache, and
- wherein upon registering the cache as a sink, the event type repository is configured to indicate that the event processor uses one or more input streams as sources of events.
8 more elements
Dependencies are inferred from the claim text.