class CustomProcessor implements Processor<Data> { public void process(Data data) { } } Pipeline<Data> pipeline = new Pipeline<>(); pipeline.addPhase(new CustomProcessor()); DataSource<Data> dataSource = new CustomDataSource(); pipeline.setDataSource(dataSource); pipeline.process();