想实现PB中数据管道的功能,希望大哥们指点!(java)
具体该怎么做?