table pipeline模块

应该是每个表会对应一个table pipeline