【大数据开发】辅助框架及工具

第14任务： 自定义source和sink