@Test( expected = IllegalArgumentException.class ) public void shouldNotGetPortRuntimeSchemaBuilderWithInvalidOutputPortIndex () { final OperatorRuntimeSchemaBuilder builder = new OperatorRuntimeSchemaBuilder( 1, 1 ); builder.getOutputPortSchemaBuilder( 1 ); }
public PortRuntimeSchemaBuilder getOutputPortSchemaBuilder ( final int portIndex ) { return getOrCreate( outputSchemaBuilders, portIndex ); }
OperatorRuntimeSchemaBuilder { public PortRuntimeSchemaBuilder getOutputPortSchemaBuilder ( final int portIndex ) { return getOrCreate( outputSchemaBuilders, portIndex ); } }
OperatorRuntimeSchemaBuilder { public PortRuntimeSchemaBuilder getOutputPortSchemaBuilder ( final int portIndex ) { return getOrCreate( outputSchemaBuilders, portIndex ); } OperatorRuntimeSchemaBuilder( final int inputPortCount, final int outputPortCount );  OperatorRuntimeSchemaBuilder( final int inputPortCount, final int outputPortCount, final OperatorSchema operatorSchema ); }
OperatorRuntimeSchemaBuilder { public PortRuntimeSchemaBuilder getOutputPortSchemaBuilder ( final int portIndex ) { return getOrCreate( outputSchemaBuilders, 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(); }
OperatorRuntimeSchemaBuilder { public PortRuntimeSchemaBuilder getOutputPortSchemaBuilder ( final int portIndex ) { return getOrCreate( outputSchemaBuilders, 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();  }