@Override
    public void init(Context context) {
      table = context.getTaskContext().getUpdatableTable("t1");
      this.received = new ArrayList<>();

      TASK_TO_MAP_FUNCTION_MAP.put(context.getTaskContext().getTaskModel().getTaskName().getTaskName(), this);
    }
This test class tests sendTo() and join() for local tables
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableEndToEnd.java