Simple batch (data partitioning using observable...)