public static MyMapFunction getMapFunctionByTask(String taskName) {
      return TASK_TO_MAP_FUNCTION_MAP.get(taskName);
    }
This test class tests sendTo() and join() for local tables
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableEndToEnd.java