@Test(expected = NullPointerException.class) public void build_NULL_DOCUMENT_PROJECT() { builder.combine(null, projectOrganizationRdd, null); }
public JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD, JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold) { Preconditions.checkNotNull(docProjRDD); Preconditions.checkNotNull(projOrgRDD); JavaPairRDD<String, AffMatchDocumentProject> projIdToDocProj = docProjRDD .keyBy(docProj -> docProj.getProjectId()) .filter(docProj -> (docProjConfidenceLevelThreshold == null || docProj._2.getConfidenceLevel() >= docProjConfidenceLevelThreshold)); JavaPairRDD<String, AffMatchProjectOrganization> projIdToProjOrg = projOrgRDD .keyBy(projOrg -> projOrg.getProjectId()); return projIdToDocProj.join(projIdToProjOrg).map(x -> { return new AffMatchDocumentOrganization(x._2._1.getDocumentId(), x._2._2.getOrganizationId()); }).distinct(); }
DocumentOrganizationCombiner implements Serializable { public JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD, JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold) { Preconditions.checkNotNull(docProjRDD); Preconditions.checkNotNull(projOrgRDD); JavaPairRDD<String, AffMatchDocumentProject> projIdToDocProj = docProjRDD .keyBy(docProj -> docProj.getProjectId()) .filter(docProj -> (docProjConfidenceLevelThreshold == null || docProj._2.getConfidenceLevel() >= docProjConfidenceLevelThreshold)); JavaPairRDD<String, AffMatchProjectOrganization> projIdToProjOrg = projOrgRDD .keyBy(projOrg -> projOrg.getProjectId()); return projIdToDocProj.join(projIdToProjOrg).map(x -> { return new AffMatchDocumentOrganization(x._2._1.getDocumentId(), x._2._2.getOrganizationId()); }).distinct(); } }
DocumentOrganizationCombiner implements Serializable { public JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD, JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold) { Preconditions.checkNotNull(docProjRDD); Preconditions.checkNotNull(projOrgRDD); JavaPairRDD<String, AffMatchDocumentProject> projIdToDocProj = docProjRDD .keyBy(docProj -> docProj.getProjectId()) .filter(docProj -> (docProjConfidenceLevelThreshold == null || docProj._2.getConfidenceLevel() >= docProjConfidenceLevelThreshold)); JavaPairRDD<String, AffMatchProjectOrganization> projIdToProjOrg = projOrgRDD .keyBy(projOrg -> projOrg.getProjectId()); return projIdToDocProj.join(projIdToProjOrg).map(x -> { return new AffMatchDocumentOrganization(x._2._1.getDocumentId(), x._2._2.getOrganizationId()); }).distinct(); }  }
DocumentOrganizationCombiner implements Serializable { public JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD, JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold) { Preconditions.checkNotNull(docProjRDD); Preconditions.checkNotNull(projOrgRDD); JavaPairRDD<String, AffMatchDocumentProject> projIdToDocProj = docProjRDD .keyBy(docProj -> docProj.getProjectId()) .filter(docProj -> (docProjConfidenceLevelThreshold == null || docProj._2.getConfidenceLevel() >= docProjConfidenceLevelThreshold)); JavaPairRDD<String, AffMatchProjectOrganization> projIdToProjOrg = projOrgRDD .keyBy(projOrg -> projOrg.getProjectId()); return projIdToDocProj.join(projIdToProjOrg).map(x -> { return new AffMatchDocumentOrganization(x._2._1.getDocumentId(), x._2._2.getOrganizationId()); }).distinct(); }  JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD,
            JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold); }
DocumentOrganizationCombiner implements Serializable { public JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD, JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold) { Preconditions.checkNotNull(docProjRDD); Preconditions.checkNotNull(projOrgRDD); JavaPairRDD<String, AffMatchDocumentProject> projIdToDocProj = docProjRDD .keyBy(docProj -> docProj.getProjectId()) .filter(docProj -> (docProjConfidenceLevelThreshold == null || docProj._2.getConfidenceLevel() >= docProjConfidenceLevelThreshold)); JavaPairRDD<String, AffMatchProjectOrganization> projIdToProjOrg = projOrgRDD .keyBy(projOrg -> projOrg.getProjectId()); return projIdToDocProj.join(projIdToProjOrg).map(x -> { return new AffMatchDocumentOrganization(x._2._1.getDocumentId(), x._2._2.getOrganizationId()); }).distinct(); }  JavaRDD<AffMatchDocumentOrganization> combine(JavaRDD<AffMatchDocumentProject> docProjRDD,
            JavaRDD<AffMatchProjectOrganization> projOrgRDD, Float docProjConfidenceLevelThreshold);  }