@@ -3,31 +3,18 @@ package com.twitter.scalding.beam_backend
33import com .twitter .chill .KryoInstantiator
44import com .twitter .chill .config .ScalaMapConfig
55import com .twitter .scalding .Config
6- import com .twitter .scalding .beam_backend .BeamOp .CoGroupedOp
7- import com .twitter .scalding .beam_backend .BeamOp .MergedBeamOp
8- import com .twitter .scalding .dagon .FunctionK
9- import com .twitter .scalding .dagon .Memoize
10- import com .twitter .scalding .dagon .Rule
6+ import com .twitter .scalding .beam_backend .BeamOp .{CoGroupedOp , MergedBeamOp }
7+ import com .twitter .scalding .dagon .{FunctionK , Memoize , Rule }
118import com .twitter .scalding .serialization .KryoHadoop
12- import com .twitter .scalding .typed .CoGrouped .WithDescription
13- import com .twitter .scalding .typed .OptimizationRules .AddExplicitForks
14- import com .twitter .scalding .typed .OptimizationRules .ComposeDescriptions
15- import com .twitter .scalding .typed .OptimizationRules .DeferMerge
16- import com .twitter .scalding .typed .OptimizationRules .DiamondToFlatMap
17- import com .twitter .scalding .typed .OptimizationRules .FilterKeysEarly
18- import com .twitter .scalding .typed .OptimizationRules .IgnoreNoOpGroup
19- import com .twitter .scalding .typed .OptimizationRules .MapValuesInReducers
20- import com .twitter .scalding .typed .OptimizationRules .RemoveDuplicateForceFork
21- import com .twitter .scalding .typed .OptimizationRules .RemoveUselessFork
22- import com .twitter .scalding .typed .OptimizationRules .composeIntoFlatMap
23- import com .twitter .scalding .typed .OptimizationRules .composeSame
24- import com .twitter .scalding .typed .OptimizationRules .simplifyEmpty
9+ import com .twitter .scalding .typed .OptimizationRules ._
2510import com .twitter .scalding .typed ._
2611import com .twitter .scalding .typed .cascading_backend .CascadingExtensions .ConfigCascadingExtensions
27- import com .twitter .scalding .typed .functions .FilterKeysToFilter
28- import com .twitter .scalding .typed .functions .FlatMapValuesToFlatMap
29- import com .twitter .scalding .typed .functions .MapValuesToMap
30- import com .twitter .scalding .typed .functions .ScaldingPriorityQueueMonoid
12+ import com .twitter .scalding .typed .functions .{
13+ FilterKeysToFilter ,
14+ FlatMapValuesToFlatMap ,
15+ MapValuesToMap ,
16+ ScaldingPriorityQueueMonoid
17+ }
3118
3219object BeamPlanner {
3320 def plan (
0 commit comments