OperatorRuntimeSchemaBuilder { public PortRuntimeSchemaBuilder getInputPortSchemaBuilder ( final int portIndex ) { return getOrCreate( inputSchemaBuilders, portIndex ); } OperatorRuntimeSchemaBuilder( final int inputPortCount, final int outputPortCount );  OperatorRuntimeSchemaBuilder( final int inputPortCount, final int outputPortCount, final OperatorSchema operatorSchema ); PortRuntimeSchemaBuilder getInputPortSchemaBuilder( final int portIndex ); PortRuntimeSchemaBuilder getOutputPortSchemaBuilder( final int portIndex ); OperatorRuntimeSchemaBuilder addInputField( final int portIndex, final String fieldName, final Class<?> type ); OperatorRuntimeSchemaBuilder addOutputField( final int portIndex, final String fieldName, final Class<?> type ); OperatorRuntimeSchema build();  }
@Test( expected = IllegalArgumentException.class ) public void shouldNotGetPortRuntimeSchemaBuilderWithNegativeInputPortIndex () { final OperatorRuntimeSchemaBuilder builder = new OperatorRuntimeSchemaBuilder( 1, 1 ); builder.getInputPortSchemaBuilder( -1 ); }
@Test( expected = IllegalArgumentException.class ) public void shouldNotGetPortRuntimeSchemaBuilderWithInvalidInputPortIndex () { final OperatorRuntimeSchemaBuilder builder = new OperatorRuntimeSchemaBuilder( 1, 1 ); builder.getInputPortSchemaBuilder( 1 ); }