我正在尝试流音频文件,添加到我的hdfs每隔几分钟。在spark中,有大量关于使用filestream处理文本文件的文档,但是对于音频文件(如.wav格式)却没有。来自hdfs的流式文本文件的参数如下:
val linesRDD = ssc.fileStream (LongWritable, Text, TextInputFormat) (hdfs:cnesi:8085/data/test)
哪里 LongWritable = key , Text = Value , TextInputFormat = File Format
我想问的是,对于.wav音频文件,这三个参数的等效值是多少,我需要哪些库或包来传输这些数据。
我正在使用spark 1.6.1。
感谢您的帮助和指导。
暂无答案!
目前还没有任何答案,快来回答吧!