1. A computer implemented method for providing load diffusion to perform a join operation over a data stream pair using a distributed stream processing system, the computer implemented method comprising: receiving the data stream pair for correlation; partitioning the data stream pair using correlation constraints to form a partitioned data stream pair; and distributing the partitioned data stream pair among a set of server nodes for load diffusion in performing the join operation.