224225226227228229230
protected abstract Gate createGroupByGate( GroupBy element, IORole role ); protected Duct createMergeStage( Merge merge, IORole both ) { return new MergeStage( flowProcess, merge ); }