...
Code Block |
---|
@Override public void configurePipeline(PipelineConfigurer pipelineConfigurer) throws IllegalArgumentException { StageConfigurer stageConfigurer = pipelineConfigurer.getStageConfigurer(); for (Schema inputSchema =: stageConfigurer.getInputSchemagetInputSchemas()); { // perform validation if (!isValid(inputSchema)) { throw new IllegalArgumentException("reason") } stageConfigurer.setOutputSchemaaddOutputSchema(getOutputSchema(inputSchema)); } } |
If a plugin does not know what it's output schema will be, or if the output schema is not constant, it will return null. Plugins further in the pipeline will then get null as an input schema.
...