我有一个Map器（custommapper.class）和一个reducer（customreducer.class）类，我想在spark中使用它们。我可以在hadoop中使用它们，方法是创建一个job对象，然后设置所需的mapper和reducer类，如下所示：

Configuration conf = new Configuration();
    Job j = new Job(conf, "Adjacency Generator Job"); 
    j.setMapperClass(CustomMapper.class);
    j.setReducerClass(CustomReducer.class);

如何使用java在spark中实现相同的功能？我创建了一个java rdd对象，如下所示：

SparkConf conf=new SparkConf().setAppName("startingSpark").setMaster("local[*]");
    JavaSparkContext sc = new JavaSparkContext(conf); 
    JavaRDD<String> myFile = sc.textFile(args[0]);

我不知道如何使用java绑定spark中的mapper和reducer类。感谢您的帮助。