SparkSteamingで二次ソートを行う方法

Question

私は、hereという方法でSpark-Streamingでセカンダリソートを行っていました。

repartitionAndSortWithinPartitions is not a member of org.apache.spark.streaming.dstream.DStream 

コード：：だから

def ProcessDStream(lines : DStream[EventData]) {    
      val dataSetrawSorted = lines.repartitionAndSortWithinPartitions(new DataSetPartitioner(1000)) 
      } 

、DSTREAMで同じことを達成するためにどのようにしかし、それは、次のエラーが発生します。

Answer 1

使用すると、変換：

stream.transform { rdd => rdd.repartitionAndSortWithinPartitions(...) }