windows下eclipse运行Java的Spark程序不进call方法如何解决?
[mw_shl_code=java,true]JavaPairRDD<String, Integer> levels = hBaseRDD.mapToPair(
new PairFunction<Tuple2<ImmutableBytesWritable, Result>, String, Integer>() {
@Override
public Tuple2<String, Integer> call(Tuple2<ImmutableBytesWritable, Result> immutableBytesWritableResultTuple2) throws Exception {
byte[] o = immutableBytesWritableResultTuple2._2().getValue(Bytes.toBytes("SSFPXX"), Bytes.toBytes("SSFPXX"));
if (o != null) {
return new Tuple2<String, Integer>(new String(o), 200);
}
return null;
}
});[/mw_shl_code]
|
|