Patent application number | Description | Published |
20090307098 | FIXED PRICE FUEL METHOD - A method and apparatus for a customer pre-purchasing goods, such as liquid fuel, from an entity and taking possession of the goods at a later time. Fuel is dispensed at a fuel-dispensing facility operated by a third party. The customer pre-purchases the fuel, such as by transmitting money to the entity. The entity sends evidence of the pre-purchase to the customer. The customer presents the evidence of the pre-purchase to the third party. The evidence verifies the customer's right to the fuel. The third party verifies the evidence and then permits the customer to dispense the fuel, such as into a fuel tank. The entity then transmits to the third party a second amount of money related to the amount of fuel dispensed. The second amount of money is substantially equal to a value of the dispensed fuel at the second time. | 12-10-2009 |
20100145888 | SPONSORSHIP METHOD - A method of rewarding sponsored individuals after they obtain public exposure for their sponsor's trademark or other indicia. The indicia are placed on the individual's person, such as his or her clothing, vehicle or equipment, and publicity is gained. Evidence of the public exposure is communicated to the sponsor, or the proper management agent, for verification and disbursement of the fee. The communicating step can be carried out by the individual, the agent or anyone else to whom this task is assigned. This incentive to gain exposure inspires the individuals, and the fact that payment does not come until after the exposure has occurred reduces the financial risk to the sponsor of a sponsored individual who does not gain significant exposure. | 06-10-2010 |
Patent application number | Description | Published |
20110093491 | PARTITIONED QUERY EXECUTION IN EVENT PROCESSING SYSTEMS - Methods, systems, and computer-readable media are disclosed for partitioned query execution in event processing systems. A particular method includes receiving a plurality of events via an input stream. The plurality of events is partitioned into one or more groups, and a query application module is instantiated for each of the one or more groups based on a compiled query application plan. Each particular query application module for a particular group is configured to apply a query to events of the particular group to generate partial results. The method includes merging the partial results of each of the query application modules to generate merged output results and providing the output results to an output stream. | 04-21-2011 |
20110093631 | ADAPTERS FOR EVENT PROCESSING SYSTEMS - Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink. | 04-21-2011 |
20110283295 | EXTENSIBILITY MODEL FOR STREAM-BASED OPERATORS AND AGGREGATES - An extensibility framework that allows a user to write user-defined modules that include user-defined operators (UDO) and user-defined aggregators (UDA) in a non-temporal fashion without the need to worry about temporal attributes of events (or event types). The temporal domain is managed on behalf of the user, and allows the user to write operators and aggregates in the temporal data streaming domain as well as to port existing libraries of non-temporal UDOs/UDAs to the temporal data streaming domain. Temporal attributes and event types are managed for non-temporal UDOs/UDAs by the extensibility framework on behalf of the UDO/UDA writer. Windows can be employed to bridge the gap between the non-temporal domains and temporal domains. Support for complex event processing (CEP) is provided in UDOs/UDAs for base classes related to a CEP operator, CEP aggregate, CEP time sensitive operator, and CEP time sensitive aggregate. | 11-17-2011 |
20120131599 | COMPLEX EVENT PROCESSING (CEP) ADAPTERS FOR CEP SYSTEMS FOR RECEIVING OBJECTS FROM A SOURCE AND OUTPUTING OBJECTS TO A SINK - Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink. | 05-24-2012 |
20120297080 | Stream Operator - Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations. | 11-22-2012 |
20130031567 | LOCAL EVENT PROCESSING - The claimed subject matter provides a method for processing a stream of events. The method includes receiving a stream of events at a local device. The stream of events is associated with the local device. Further, the stream of events includes one or more out-of-order events. The method also includes executing a first complex event processing query against the stream of events. The stream of events is processed based on multiple levels of consistency defined by a set of operators. Additionally, the method includes correcting the out-of-order events based on the set of operators. A first output is generated in which consistency is guaranteed based on the corrected out-of-order events. The method also includes sending the first output to a server that performs complex event processing on the output. | 01-31-2013 |