草庐IT

Lzocodec

全部标签

scala - Scala Spark 中的 groupBy 函数需要 Lzocodec 吗?

我在ScalaSpark中创建了一个如下所示的函数。defprepareSequences(data:RDD[String],splitChar:Char='\t')={valx=data.map(line=>{valArray(id,se,offset,hour)=line.split(splitChar)(id+"-"+se,Step(offset=if(offset=="NULL"){-5}else{offset.toInt},hour=hour.toInt))})valy=x.groupBy(_._1)}我需要groupBy但是一旦我添加它,我就会收到错误消息。错误要求Lzoc

hadoop - Faunus 测试在未找到 com.hadoop.compression.lzo.LzoCodec 时失败,HDP1.3

你好,我在HDP1.3上安装了Faunus0.32当我按照https://github.com/thinkaurelius/faunus/wiki/Getting-Started中的入门测试用例进行操作时,我遇到了以下错误gremlin>g=FaunusFactory.open('bin/faunus.properties')==>faunusgraph[graphsoninputformat->graphsonoutputformat]gremlin>g.V.type.groupCount13/09/2921:38:49WARNmapreduce.FaunusCompiler:Usi