@Test(expected = NullPointerException.class) public void match_affiliations_null() { matcher.match(null, organizations); }
public JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations) { checkNotNull(affiliations); checkNotNull(organizations); checkNotNull(affOrgJoiner, "affOrgJoiner has not been set"); checkNotNull(affOrgMatchComputer, "affOrgMatchComputer has not been set"); JavaRDD<Tuple2<AffMatchAffiliation, AffMatchOrganization>> joinedAffOrgs = affOrgJoiner.join(affiliations, organizations); JavaRDD<AffMatchResult> matchedAffOrgs = affOrgMatchComputer.computeMatches(joinedAffOrgs); return matchedAffOrgs; }
AffOrgMatcher implements Serializable { public JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations) { checkNotNull(affiliations); checkNotNull(organizations); checkNotNull(affOrgJoiner, "affOrgJoiner has not been set"); checkNotNull(affOrgMatchComputer, "affOrgMatchComputer has not been set"); JavaRDD<Tuple2<AffMatchAffiliation, AffMatchOrganization>> joinedAffOrgs = affOrgJoiner.join(affiliations, organizations); JavaRDD<AffMatchResult> matchedAffOrgs = affOrgMatchComputer.computeMatches(joinedAffOrgs); return matchedAffOrgs; } }
AffOrgMatcher implements Serializable { public JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations) { checkNotNull(affiliations); checkNotNull(organizations); checkNotNull(affOrgJoiner, "affOrgJoiner has not been set"); checkNotNull(affOrgMatchComputer, "affOrgMatchComputer has not been set"); JavaRDD<Tuple2<AffMatchAffiliation, AffMatchOrganization>> joinedAffOrgs = affOrgJoiner.join(affiliations, organizations); JavaRDD<AffMatchResult> matchedAffOrgs = affOrgMatchComputer.computeMatches(joinedAffOrgs); return matchedAffOrgs; } AffOrgMatcher();  AffOrgMatcher(AffOrgJoiner affOrgJoiner, AffOrgMatchComputer affOrgMatchComputer); }
AffOrgMatcher implements Serializable { public JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations) { checkNotNull(affiliations); checkNotNull(organizations); checkNotNull(affOrgJoiner, "affOrgJoiner has not been set"); checkNotNull(affOrgMatchComputer, "affOrgMatchComputer has not been set"); JavaRDD<Tuple2<AffMatchAffiliation, AffMatchOrganization>> joinedAffOrgs = affOrgJoiner.join(affiliations, organizations); JavaRDD<AffMatchResult> matchedAffOrgs = affOrgMatchComputer.computeMatches(joinedAffOrgs); return matchedAffOrgs; } AffOrgMatcher();  AffOrgMatcher(AffOrgJoiner affOrgJoiner, AffOrgMatchComputer affOrgMatchComputer); JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations); void setAffOrgJoiner(AffOrgJoiner affOrgJoiner); void setAffOrgMatchComputer(AffOrgMatchComputer affOrgMatchComputer); }
AffOrgMatcher implements Serializable { public JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations) { checkNotNull(affiliations); checkNotNull(organizations); checkNotNull(affOrgJoiner, "affOrgJoiner has not been set"); checkNotNull(affOrgMatchComputer, "affOrgMatchComputer has not been set"); JavaRDD<Tuple2<AffMatchAffiliation, AffMatchOrganization>> joinedAffOrgs = affOrgJoiner.join(affiliations, organizations); JavaRDD<AffMatchResult> matchedAffOrgs = affOrgMatchComputer.computeMatches(joinedAffOrgs); return matchedAffOrgs; } AffOrgMatcher();  AffOrgMatcher(AffOrgJoiner affOrgJoiner, AffOrgMatchComputer affOrgMatchComputer); JavaRDD<AffMatchResult> match(JavaRDD<AffMatchAffiliation> affiliations, JavaRDD<AffMatchOrganization> organizations); void setAffOrgJoiner(AffOrgJoiner affOrgJoiner); void setAffOrgMatchComputer(AffOrgMatchComputer affOrgMatchComputer);  }