我想用java重写spark的sequenceFile函数，是否可行呢？

[wangfeng1981]

您好。sequenceFile返回的RDD不能正常的persist，我想重写这个功能（比如sequenceFilePersist），最终目标是让返回RDD可以不通过map函数直接persist。想请问，我需要从继承或者扩展哪个类下手呢？十分感谢。