Text this: Language design for distributed stream processing