Methods and system to process streaming data

A method, comprising:

• accessing a Streaming Data Table (SDT) from memory using a database interface to acquire portions of streaming data housed in fields of the SDT;
• processing one or more operations on the portions of the streaming data based on each portion's field identifier within the SDT;
• and
• streaming continuous results from processing the one or more operations to one or more consuming applications.

A processor-implemented system, comprising:

• a memory having at least one instance of a Streaming Data Table (SDT) with fields of the SDT having a unique portion of streaming data;
• and
• a SDT manager adapted and configured to:
• i) execute on at least one processor, ii) define and create the at least one instance of the SDT, and iii) populate each unique portion of the streaming data to that portion's designated field;
• and
• a streaming engine adapted and configured to:
• i) execute as multiple independent instances on multiple processing units of a parallel processing database environment, ii) continuously access the fields of the SDT as each field is updated with the streaming data, iii) continuously process operations on each portion of the streaming data with each update to produce results, and iv) stream the results as produced to consuming applications.