Event stream processor

Patent metadata

Field	Value
Publication number	US-9558225-B2
Application number	US-201414228871-A
Country	US
Kind code	B2
Filing date	Mar 28, 2014
Priority date	Dec 16, 2013
Publication date	Jan 31, 2017
Grant date	Jan 31, 2017

Abstract

In an example embodiment, a method for performing event stream processing is provided. An event stream is received, the event stream comprising a real time indication of one or more events occurring. Then it is determined that the event stream is identified in a streaming publish service inside a database. The event stream may then be inserted directly into one or more database tables in the database based on the determining.

First claim

What is claimed is:

1. A computer-implemented method for performing event stream processing, the method comprising:
receiving, at a computer system, an event stream, the event stream comprising a real time indication of one or more events occurring;
determining, by the computer system, that the event stream is identified in a first table inside a streaming publish service maintained inside a database, the determining including comparing an identification of the event stream to one or more entries in the first table; and
inserting, by the computer system, the event stream directly into one or more database tables, other than the first table, in the database based on the determining.

2. The method of claim 1 , wherein the database is an in-memory database.

3. The method of claim 1 , wherein the determining is performed by locating a reference to a database table inside the event stream.

4. The method of claim 3 , wherein the reference is inserted into the event stream by a designer utilizing an event stream element assigned only to providing the reference.

5. The method of claim 4 , wherein the reference, when executed, prompts a user to define or select a database service, a name of a table from which the information should be received, and a schema of the information in the table.

6. The method of claim 5 , wherein the reference, when executed, additionally prompts the user to specify a primary key for the table.

7. The method of claim 5 , wherein the reference, when executed, additionally prompts the user to enable the reference to attempt reconnection to the database when a connection is lost during data flow.

8. A database comprising:
data storage including one or more database tables; and
a database management system including a streaming publish service, the streaming publish service executable by a processor and configured to determine that an incoming event stream is identified in first table inside a streaming publish service, the determining including comparing an identification of the event stream to one or more entries in the first table and to insert the event stream directly into the one or more database tables, other than the first table, in the data storage based on the determining.

9. The database of claim 8 , wherein the database is an in-memory database.

10. The database of claim 8 , wherein the determining is performed by locating a reference to a database table inside the event stream.

11. The database of claim 10 , wherein the reference is inserted into the event stream by a designer utilizing an event stream element assigned only to providing the reference.

12. The database of claim 11 , wherein the reference, when executed, prompts a user to define or select a database service, a name of a table from which the information should be received, and a schema of the information in the table.

13. The database of claim 12 , wherein the reference, when executed, additionally prompts the user to specify a primary key for the table.

14. The database of claim 12 , wherein the reference, when executed, additionally prompts the user to enable the reference to attempt reconnection to the database when a connection is lost during data flow.

15. A non-transitory machine-readable storage medium comprising instructions, which when implemented by one or more machines, cause the one or more machines to perform operations comprising:
receiving an event stream, the event stream comprising a real time indication of one or more events occurring;
determining, by the computer system, that the event stream is identified in a first table inside a streaming publish service maintained inside a database, the determining including comparing an identification of the event stream to one or more entries in the first table; and
inserting, by the computer system, the event stream directly into one or more database tables, other than the first table, in the database based on the determining.

16. The non-transitory machine-readable storage medium of claim 15 , wherein the database is an in-memory database.

17. The non-transitory machine-readable storage medium of claim 15 , wherein the determining is performed by locating a reference to a database table inside the event stream.

18. The non-transitory machine-readable storage medium of claim 17 , wherein the reference is inserted into the event stream by a designer utilizing an event stream element assigned only to providing the reference.

19. The non-transitory machine-readable storage medium of claim 18 , wherein the reference, when executed, prompts a user to define or select a database service, a name of a table from which the information should be received, and a schema of the information in the table.

20. The non-transitory machine-readable storage medium of claim 19 , wherein the reference, when executed, additionally prompts the user to specify a primary key for the table.

Assignees

• Skrzypczak Joe
• Kucharczyk Andrzej
• Frantz Andrew
• Wang Gerald
• Theiding Mark
• Sybase Inc

Inventors

• Skrzypczak Joe
• Kucharczyk Andrzej
• Frantz Andrew
• Wang Gerald
• Theiding Mark

Classifications

• G06F16/2282 Primary

  Tablespace storage structures; Management thereof · CPC title

• G06F16/23

  Updating · CPC title

• G06F17/30339 Primary

  Physics · mapped topic

• G06F17/30345

  Physics · mapped topic