@Test(expected = NullPointerException.class) public void readProjectOrganizations_NULL_PATH() { projectOrganizationReader.readProjectOrganizations(sparkContext, null); }
@Override public JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, ProjectToOrganization.class) .map(srcProjOrg -> converter.convert(srcProjOrg)); }
IisProjectOrganizationReader implements ProjectOrganizationReader { @Override public JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, ProjectToOrganization.class) .map(srcProjOrg -> converter.convert(srcProjOrg)); } }
IisProjectOrganizationReader implements ProjectOrganizationReader { @Override public JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, ProjectToOrganization.class) .map(srcProjOrg -> converter.convert(srcProjOrg)); }  }
IisProjectOrganizationReader implements ProjectOrganizationReader { @Override public JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, ProjectToOrganization.class) .map(srcProjOrg -> converter.convert(srcProjOrg)); }  @Override JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath); void setAvroLoader(SparkAvroLoader avroLoader); void setProjectOrganizationConverter(ProjectOrganizationConverter converter); }
IisProjectOrganizationReader implements ProjectOrganizationReader { @Override public JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath) { return avroLoader.loadJavaRDD(sc, inputPath, ProjectToOrganization.class) .map(srcProjOrg -> converter.convert(srcProjOrg)); }  @Override JavaRDD<AffMatchProjectOrganization> readProjectOrganizations(JavaSparkContext sc, String inputPath); void setAvroLoader(SparkAvroLoader avroLoader); void setProjectOrganizationConverter(ProjectOrganizationConverter converter);  }