Kafka写数据到hdfs中代码问题

老师好,请问在这个过程中,需要自我定制一些功能,比如加入日期到文件名中,我看冼老师的讲解中有java代码,尤其是dumpToFile,包括run(), 这个是要改写已有的代码吗?比如hadoop_consumer这个有原始的示例代码参考一下吗?现在自己直接写也不知道该有那些具体函数需要继承,哪些需要实现?谢谢。

wangxiaolei

赞同来自: zhudejun_1985

示例代码在bootcamp项目中已经给出,如下图:
1478829691733.png
 

要回复问题请先登录注册