Scalable stream join processing with expensive predicates: workload distribution and adaptation by time-slicing.