Hi, I'm new to SparkStreaming.
I'm using the versions 2.10 for spark core and spark streaming My issue is that when i try to use JavaPairDStream.foreachRDD : test.foreachRDD(new Function<JavaPairRDD<Integer, Long>,Void>() { public Void call(JavaPairRDD<Integer, Long> rdd) { currentResponseCodeCounts = rdd.take(100); return null; }}); it says this : The method foreachRDD(Function <JavaPairRDD<String,Long>,Void>) in the type AbstractJavaDStreamLike<Tuple2<String,Long>,JavaPairDStream<String,Long>,JavaPairRDD<Function<JavaPairRDD<String,Long>> is not applicable for the arguments (new Function<JavaPairRDD<Integer,Long>,Void>(){}) I can't figure out what i'm missing. Thanx.