kafka变量初始化的问题

雷雷,同样是在SubTestConsumer源文件中,synchronized (syncObj)这里面的syncObj应该如何定义?我知道它应该是一个类类型,但是怎么定义呢?
第二个,outputFileName初始化成什么呢?直接设成null好像不对,应该outputFileName = destDir 吗?

wangxiaolei

赞同来自:

Object类型,自己定义的成员变量。 直接定义即可,不需要写等号。 如:
图片.png
 

zhudejun_1985 - 天下大事,必作于细

赞同来自:

outputFileName这个我的理解:仅仅是我自己随便起个名字吧?比如zhudejun_kafka,并不涉及在HDFS上的存储路径。之前我理解成也是个需要配置的绝对路径了。这个理解对吗?

wangxiaolei

赞同来自:

先弄清楚当前这个类的作用是讲kafa中的数据存储到hdfs上,那么outpuFileName最终映射的是HDFS的存储路径。 这个路径是按照一定的规则拼凑出来的,指定程序写到那个目下的文件。 当数据都写完时,一般标记.Done,来表示数据写入完成,后来的数据就不再写到该文件。 会依据程序的逻辑,来控制数据要写入那个文件。 请认真思考下代码逻辑,如下,
图片.png
 

要回复问题请先登录注册