火花轉換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; 
    } 
});