### Question:
DeepSparkContext extends JavaSparkContext implements Serializable { public static JavaRDD<Row> createJavaRowRDD(JavaRDD<Cells> cellsRDD) throws UnsupportedDataTypeException { JavaRDD<Row> result = cellsRDD.map(new Function<Cells, Row>() { @Override public Row call(Cells cells) throws Exception { return CellsUtils.getRowFromCells(cells); } }); return result; } DeepSparkContext(SparkContext sc);  DeepSparkContext(String master, String appName);  DeepSparkContext(String master, String appName, String sparkHome, String jarFile);  DeepSparkContext(String master, String appName, String sparkHome, String[] jars);  DeepSparkContext(String master, String appName, String sparkHome, String[] jars,
                            Map<String, String> environment);  DeepSparkContext(DeepSparkConfig deepSparkConfig); @Override SparkContext sc(); RDD<T> createRDD(ExtractorConfig<T> config); RDD<T> createRDD(DeepJobConfig<T, ?> deepJobConfig); JavaRDD<T> createJavaRDD(
            ExtractorConfig<T> config); JavaRDD<T> createJavaRDD(DeepJobConfig<T, ?> config); static JavaRDD<Row> createJavaRowRDD(JavaRDD<Cells> cellsRDD); DataFrame createJavaSchemaRDD(ExtractorConfig<Cells> config); DataFrame sql(String query); static void saveRDD(RDD<T> rdd, S config, UpdateQueryBuilder queryBuilder); static void saveRDD(RDD<T> rdd, S config); SQLContext getSQLContext(); RDD textFile(ExtractorConfig<Cells> config); RDD<Cells> createHDFSRDD(ExtractorConfig<Cells> config); RDD<Cells> createS3RDD(ExtractorConfig<Cells> config);  }### Answer:
@Test public void createJavaRowRDD() throws Exception { DeepSparkContext deepSparkContext = createDeepSparkContext(); deepSparkContext.createJavaRowRDD(singleRdd); verify(singleRdd).map(any(Function.class)); }