Methods, systems, and apparatus, including computer programs encoded on computer
storage media, for receiving a request from a client to process a computational graph; …

A stream application may allocate processing elements to one or more compute nodes (or
hosts) to achieve a desired optimization goal. Each optimization mode may define …

(57) ABSTRACT A system and associated method for continuously optimizing data archive
management scheduling. A job Scheduler receives, from an archive management system …

Techniques are described for debugging a processing element (or elements) in a stream
based database application in a manner that reduces the impact of debugging the …

Methods, systems, and apparatus, including computer pro grams encoded on computer
storage media, for placement and scheduling of radio signal processing dataflow opera …

G06F 9/44(2006.01)(57) ABSTRACT G06F 9/45(2006.01) In one embodiment, a method for
call graph analysis is pro (52) US Cl. vided. The method includes determining a plurality of …

(57) ABSTRACT A stream application may allocate processing elements to one or more
compute nodes (or hosts) to achieve a desired opti mization goal. Each optimization mode …

In a stream computing application, data may be transmitted between operators using tuples.
However, the receiving operator may not evaluate these tuples as they arrive but instead …

Techniques for partitioning an operator flow graph are provided. The techniques include
receiving source code for a stream processing application, wherein the source code …

(57) ABSTRACT A streams manager monitors cost of one or more VMS hosting a streaming
application, determines when cost can be reduced, and requests a cloud manager provision …