@@ -243,10 +243,10 @@ class PlannerSuite extends SparkFunSuite with SQLTestUtils {
243243 // repartition both inputs prior to performing the join:
244244 assert(! leftPartitioning.guarantees(rightPartitioning))
245245 assert(! rightPartitioning.guarantees(leftPartitioning))
246- val inputPlan = DummyPlan (
246+ val inputPlan = DummySparkPlan (
247247 children = Seq (
248- DummyPlan (outputPartitioning = leftPartitioning),
249- DummyPlan (outputPartitioning = rightPartitioning)
248+ DummySparkPlan (outputPartitioning = leftPartitioning),
249+ DummySparkPlan (outputPartitioning = rightPartitioning)
250250 ),
251251 requiresChildPartitioningsToBeCompatible = true ,
252252 requiredChildDistribution = Seq (distribution, distribution),
@@ -264,10 +264,10 @@ class PlannerSuite extends SparkFunSuite with SQLTestUtils {
264264 // unless they produce the same number of partitions.
265265 val clustering = Literal (1 ) :: Nil
266266 val distribution = ClusteredDistribution (clustering)
267- val inputPlan = DummyPlan (
267+ val inputPlan = DummySparkPlan (
268268 children = Seq (
269- DummyPlan (outputPartitioning = HashPartitioning (clustering, 1 )),
270- DummyPlan (outputPartitioning = HashPartitioning (clustering, 2 ))
269+ DummySparkPlan (outputPartitioning = HashPartitioning (clustering, 1 )),
270+ DummySparkPlan (outputPartitioning = HashPartitioning (clustering, 2 ))
271271 ),
272272 requiresChildPartitioningsToBeCompatible = true ,
273273 requiredChildDistribution = Seq (distribution, distribution),
@@ -283,10 +283,10 @@ class PlannerSuite extends SparkFunSuite with SQLTestUtils {
283283 // distribution because they are clustered on different columns. Thus, we need to shuffle.
284284 val childPartitioning = HashPartitioning (Literal (2 ) :: Nil , 1 )
285285 assert(! childPartitioning.satisfies(distribution))
286- val inputPlan = DummyPlan (
286+ val inputPlan = DummySparkPlan (
287287 children = Seq (
288- DummyPlan (outputPartitioning = childPartitioning),
289- DummyPlan (outputPartitioning = childPartitioning)
288+ DummySparkPlan (outputPartitioning = childPartitioning),
289+ DummySparkPlan (outputPartitioning = childPartitioning)
290290 ),
291291 requiresChildPartitioningsToBeCompatible = true ,
292292 requiredChildDistribution = Seq (distribution, distribution),
@@ -304,10 +304,10 @@ class PlannerSuite extends SparkFunSuite with SQLTestUtils {
304304 val distribution = ClusteredDistribution (Literal (1 ) :: Nil )
305305 val childPartitioning = HashPartitioning (Literal (1 ) :: Nil , 5 )
306306 assert(childPartitioning.satisfies(distribution))
307- val inputPlan = DummyPlan (
307+ val inputPlan = DummySparkPlan (
308308 children = Seq (
309- DummyPlan (outputPartitioning = childPartitioning),
310- DummyPlan (outputPartitioning = childPartitioning)
309+ DummySparkPlan (outputPartitioning = childPartitioning),
310+ DummySparkPlan (outputPartitioning = childPartitioning)
311311 ),
312312 requiresChildPartitioningsToBeCompatible = true ,
313313 requiredChildDistribution = Seq (distribution, distribution),
@@ -328,10 +328,10 @@ class PlannerSuite extends SparkFunSuite with SQLTestUtils {
328328 // should not need to add additional shuffles / exchanges.
329329 val outputOrdering = Seq (SortOrder (Literal (1 ), Ascending ))
330330 val distribution = ClusteredDistribution (Literal (1 ) :: Nil )
331- val inputPlan = DummyPlan (
331+ val inputPlan = DummySparkPlan (
332332 children = Seq (
333- DummyPlan (outputPartitioning = SinglePartition ),
334- DummyPlan (outputPartitioning = SinglePartition )
333+ DummySparkPlan (outputPartitioning = SinglePartition ),
334+ DummySparkPlan (outputPartitioning = SinglePartition )
335335 ),
336336 requiresChildPartitioningsToBeCompatible = true ,
337337 requiredChildDistribution = Seq (distribution, distribution),
@@ -348,7 +348,7 @@ class PlannerSuite extends SparkFunSuite with SQLTestUtils {
348348}
349349
350350// Used for unit-testing EnsureRequirements
351- private case class DummyPlan (
351+ private case class DummySparkPlan (
352352 override val children : Seq [SparkPlan ] = Nil ,
353353 override val outputOrdering : Seq [SortOrder ] = Nil ,
354354 override val outputPartitioning : Partitioning = UnknownPartitioning (0 ),
0 commit comments