@Override
    public KV<Integer, Profile> apply(Profile profile) {
      received.add(profile);
      return new KV<>(profile.getMemberId(), profile);
    }
This test class tests sendTo() and join() for local tables
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableEndToEnd.java