@Test(expected = NullPointerException.class) public void readDocumentProjects_NULL_CONTEXT() { documentProjectReader.readDocumentProjects(null, inputDocProjPath); }
@Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { Preconditions.checkNotNull(sc); Preconditions.checkArgument(StringUtils.isNotBlank(inputPath)); return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(docProj -> converter.convert(docProj)); }
IisDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { Preconditions.checkNotNull(sc); Preconditions.checkArgument(StringUtils.isNotBlank(inputPath)); return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(docProj -> converter.convert(docProj)); } }
IisDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { Preconditions.checkNotNull(sc); Preconditions.checkArgument(StringUtils.isNotBlank(inputPath)); return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(docProj -> converter.convert(docProj)); }  }
IisDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { Preconditions.checkNotNull(sc); Preconditions.checkArgument(StringUtils.isNotBlank(inputPath)); return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(docProj -> converter.convert(docProj)); }  @Override JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath); }
IisDocumentProjectReader implements DocumentProjectReader { @Override public JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath) { Preconditions.checkNotNull(sc); Preconditions.checkArgument(StringUtils.isNotBlank(inputPath)); return avroLoader.loadJavaRDD(sc, inputPath, DocumentToProject.class) .map(docProj -> converter.convert(docProj)); }  @Override JavaRDD<AffMatchDocumentProject> readDocumentProjects(JavaSparkContext sc, String inputPath);  }