我对使用linkedin的加缪相当陌生,并成功地将Kafka的数据文件写入了hdfs。一般来说,我用 JsonStringMessagdecoder
读取json并将其写入 .dat
文件使用 StringRecordWriterProvider
.
但是有可能写入多种文件类型吗?
假设json在 kafka
具体如下:
{ "user":"John", "message":"Hi how are you?" }
现在我想要 John,Hi how are you?
写入一个文件,而 user,message
写入另一个文件( .meta
)在同一地点。有可能吗?
暂无答案!
目前还没有任何答案,快来回答吧!