如何修改reader组件的逻辑？

[AzurLu]

您好！我目前的需求是添加一个自定义的样本选择算法的组件，需要对读入的数据进行处理，替换掉原有的reader组件，即后续在pipeline中依次使用“自定义组件→psi→sshe_lr”来进行任务。并且由于算法的特殊性，无法在使用reader组件读取数据后再进行处理，必须替换掉原有的reader（在读取数据前进行处理）。请问reader具体的读入逻辑是什么？我应该如何修改reader相关代码？