MCPcopy Create free account
hub / github.com/apache/datafusion / repartition

Method repartition

datafusion/expr/src/logical_plan/builder.rs:1263–1268  ·  view source on GitHub ↗

Repartition

(self, partitioning_scheme: Partitioning)

Source from the content-addressed store, hash-verified

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(

Callers

nothing calls this directly

Calls 2

newFunction · 0.85
RepartitionClass · 0.85

Tested by

no test coverage detected