...
| Code Block |
|---|
@Override
public void configurePipeline(PipelineConfigurer pipelineConfigurer) throws IllegalArgumentException {
StageConfigurer stageConfigurer = pipelineConfigurer.getStageConfigurer();
for (Schema inputSchema : stageConfigurer.getInputSchemas()) {
// perform validation
if (!isValid(inputSchemastageConfigurer.getInputSchema())) {
throw new IllegalArgumentException("reason")
}
stageConfigurer.addOutputSchemasetOutputSchema(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.
...