## Repartitioning Operation. Every tuple is replicated to all target partitions. This can useful during DRPC – for example, if you need to do a stateQuery on every partition of data.
()
| 261 | * every partition of data. |
| 262 | */ |
| 263 | public Stream broadcast() { |
| 264 | return partition(Grouping.all(new NullStruct())); |
| 265 | } |
| 266 | |
| 267 | /** |
| 268 | * ## Repartitioning Operation. |