@Test(expected = NullPointerException.class) public void readDocumentProjects_NULL_CONTEXT() { documentProjectReader.readDocumentProjects(null, predefinedPath); }
@Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(srcDocProj -> converter.convert(srcDocProj)); }
IisInferredDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(srcDocProj -> converter.convert(srcDocProj)); } }
IisInferredDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(srcDocProj -> converter.convert(srcDocProj)); }  }
IisInferredDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(srcDocProj -> converter.convert(srcDocProj)); }  @Override JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath); void setAvroLoader(SparkAvroLoader avroLoader); void setDocumentProjectConverter(InferredDocumentProjectConverter converter); }
IisInferredDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(srcDocProj -> converter.convert(srcDocProj)); }  @Override JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath); void setAvroLoader(SparkAvroLoader avroLoader); void setDocumentProjectConverter(InferredDocumentProjectConverter converter);  }