Load imbalance in a single node in a distributed stream processing system and language, and programming models and code generation techniques for the Cell processor.