[scala] [streaming] Temporal join operator added