1. A system for adaptive auto-pipelining of a stream processing application having at least one thread, said system comprising: a stream processing application manager for initiating runtime of the stream processing application; a monitoring module connected to said stream processing application manager, said monitoring module monitors the stream processing application during the runtime to: identify threads in the stream processing application that execute operators in a data flow graph, and determine an amount of work that each of the threads are performing on operators of the logical data flow graph; and a processor connected to said monitoring module, said processor identifies at least one operator in the data flow graph to add at least one additional thread based on the monitoring of the stream processing application during the runtime.