从数据源的地方把数据推送到集群中，需要编写 usertask 程序来解析原始数据，然后将解析后的数据导入数据集市。请参考 Parse CSV 例子。