Implement two partition writers: - [ ] fanout partition writer: partition in writer - [ ] partition writer: write the data already partitioned