×

Support for user defined functions in a data stream management system

  • US 8,543,558 B2
  • Filed: 09/23/2011
  • Issued: 09/24/2013
  • Est. Priority Date: 10/18/2007
  • Status: Active Grant
First Claim
Patent Images

1. A method implemented in at least one computer, the method comprising:

  • receiving a plurality of incoming streams of data;

    wherein the data in each incoming stream arrives indefinitely;

    processing the data received in the plurality of incoming streams, to execute thereon a plurality of continuous queries based on an existing global plan;

    during said processing, receiving from a user, a command to create a function and identification of a set of instructions to be executed to perform the function;

    in response to receipt of said command, creating in a memory of said at least one computer, an instance of the set of instructions identified by the identification received from the user, and a first structure comprising a pointer to the instance of the set of instructions;

    during said processing, receiving a new continuous query to be executed using the function;

    during said processing, based on the first structure, creating in the memory an operator to invoke the instance of the set of instructions, the operator comprising a second structure, the second structure comprising a first field to hold the pointer to the instance of the set of instructions, and at least one additional field corresponding to at least one argument of the function;

    during said processing, at least one processor in said at least one computer modifying the existing global plan by adding thereto said operator, thereby to obtain a modified global plan;

    altering said processing, to cause execution of the new continuous query in addition to the plurality of continuous queries, based on the modified global plan, thereby to perform the function; and

    based at least partially on processing of at least a portion of the data by executing the new continuous query, outputting from said at least one computer an output stream of data;

    wherein during the execution of the new continuous query, the instance of the set of instructions is invoked repeatedly on receipt of each tuple of the data without re-creating the instance of the set of instructions.

View all claims
  • 0 Assignments
Timeline View
Assignment View
    ×
    ×