Repartition
(self, partitioning_scheme: Partitioning)
| 1261 | |
| 1262 | /// Repartition |
| 1263 | pub fn repartition(self, partitioning_scheme: Partitioning) -> Result<Self> { |
| 1264 | Ok(Self::new(LogicalPlan::Repartition(Repartition { |
| 1265 | input: self.plan, |
| 1266 | partitioning_scheme, |
| 1267 | }))) |
| 1268 | } |
| 1269 | |
| 1270 | /// Apply a window functions to extend the schema |
| 1271 | pub fn window( |
nothing calls this directly
no test coverage detected