@Test( expected = IllegalArgumentException.class ) public void shouldNotAddOperatorMultipleTimesWithSameOperatorId () { builder.add( OperatorDefBuilder.newInstance( "op1", StatefulOperatorWithFixedPortCounts.class ) ); builder.add( OperatorDefBuilder.newInstance( "op1", StatefulOperatorWithFixedPortCounts.class ) ); }
public FlowDefBuilder add ( final OperatorDefBuilder operatorDefBuilder ) { add( operatorDefBuilder.build() ); return this; }
FlowDefBuilder { public FlowDefBuilder add ( final OperatorDefBuilder operatorDefBuilder ) { add( operatorDefBuilder.build() ); return this; } }
FlowDefBuilder { public FlowDefBuilder add ( final OperatorDefBuilder operatorDefBuilder ) { add( operatorDefBuilder.build() ); return this; }  }
FlowDefBuilder { public FlowDefBuilder add ( final OperatorDefBuilder operatorDefBuilder ) { add( operatorDefBuilder.build() ); return this; }  FlowDef build(); FlowDefBuilder add( final OperatorDefBuilder operatorDefBuilder ); FlowDefBuilder add( final OperatorDef operatorDef ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, int sourcePort, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId, final int destinationPort ); FlowDefBuilder connect( final String sourceOperatorId,
                                    final int sourcePort,
                                    final String destinationOperatorId,
                                    final int destinationPort ); }
FlowDefBuilder { public FlowDefBuilder add ( final OperatorDefBuilder operatorDefBuilder ) { add( operatorDefBuilder.build() ); return this; }  FlowDef build(); FlowDefBuilder add( final OperatorDefBuilder operatorDefBuilder ); FlowDefBuilder add( final OperatorDef operatorDef ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, int sourcePort, final String destinationOperatorId ); FlowDefBuilder connect( final String sourceOperatorId, final String destinationOperatorId, final int destinationPort ); FlowDefBuilder connect( final String sourceOperatorId,
                                    final int sourcePort,
                                    final String destinationOperatorId,
                                    final int destinationPort );  }