SplitPipelineAction implements AdaptationAction { @Override public void apply ( final AdaptationPerformer performer ) { performer.splitPipeline( pipelineId, pipelineOperatorIndices ); } SplitPipelineAction( final RegionExecPlan execPlan, final PipelineId pipelineId, final int pipelineOperatorIndex );  SplitPipelineAction( final RegionExecPlan execPlan, final PipelineId pipelineId, final List<Integer> pipelineOperatorIndices ); @Override void apply( final AdaptationPerformer performer ); @Override RegionExecPlan getCurrentExecPlan(); @Override RegionExecPlan getNewExecPlan(); @Override AdaptationAction revert(); @Override String toString(); @Override boolean equals( final Object o ); @Override int hashCode();  }
@Test public void testSplitPipelinesActionApply () { final PipelineId splitPipelineId = regionExecPlan.getPipelineId( 1 ); final List<Integer> pipelineOperatorIndices = singletonList( 3 ); final SplitPipelineAction action = new SplitPipelineAction( regionExecPlan, splitPipelineId, pipelineOperatorIndices ); final AdaptationPerformer adaptationPerformer = mock( AdaptationPerformer.class ); action.apply( adaptationPerformer ); verify( adaptationPerformer ).splitPipeline( splitPipelineId, pipelineOperatorIndices ); }