We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5db3ce0 commit 1cd6329Copy full SHA for 1cd6329
src/execution_plans/partition_isolator.rs
@@ -222,3 +222,36 @@ impl ExecutionPlan for PartitionIsolatorExec {
222
output_stream
223
}
224
225
+
226
+#[cfg(test)]
227
+mod tests {
228
+ use super::*;
229
230
+ #[test]
231
+ fn test_partition_groups() {
232
+ assert_eq!(
233
+ PartitionIsolatorExec::partition_groups(2, 1),
234
+ vec![vec![0, 1]]
235
+ );
236
237
+ PartitionIsolatorExec::partition_groups(6, 2),
238
+ vec![vec![0, 1, 2], vec![3, 4, 5]]
239
240
241
+ PartitionIsolatorExec::partition_groups(6, 3),
242
+ vec![vec![0, 1], vec![2, 3], vec![4, 5]]
243
244
245
+ PartitionIsolatorExec::partition_groups(6, 4),
246
+ vec![vec![0, 1], vec![2, 3], vec![4], vec![5]]
247
248
249
+ PartitionIsolatorExec::partition_groups(10, 3),
250
+ vec![vec![0, 1, 2, 3], vec![4, 5, 6], vec![7, 8, 9]]
251
252
253
+ PartitionIsolatorExec::partition_groups(10, 4),
254
+ vec![vec![0, 1, 2], vec![3, 4, 5], vec![6, 7], vec![8, 9]]
255
256
+ }
257
+}
0 commit comments