[scala] [streaming] Temporal cross operator added