火花转换JavaDStream <String>方法JavaPairDStream <字符串，字符串>方法

Question

我在火花流代码此功能其将鸣叫为单个单词

JavaDStream<String> words = statuses 
       .flatMap(new FlatMapFunction<String, String>() { 
        public Iterable<String> call(String in) { 
         return Arrays.asList(in.split(" ")); 
        } 
       }); 

我需要修改它，使它返回字和针对每个单词的原始推文。我已经尝试了下面的内容，但是我在运行时遇到了java.lang.ClassCastException: scala.Tuple2 cannot be cast to java.lang.Iterable错误。

JavaPairDStream<String, String> wordTweets = statuses.flatMapToPair(
      new PairFlatMapFunction<String, String, String>() { 
       public Iterable<Tuple2<String, String>> call(String in){ 
        Tuple2<String, String> tuple2 = new Tuple2(Arrays.asList(in.split(" ")), in); 
        return (Iterable<Tuple2<String, String>>) tuple2; 
       } 
      }); 

Answer 1

使用以下方法来获得功能

JavaPairDStream<String, String> locationspairRdd=OutStreamRDD.mapToPair(new PairFunction<String, String, String>() { 
    public Tuple2<String, String> call(String arg0) throws Exception { 
     return null; 
    } 
});