@Override
  protected void handleInit(Context context) {
    this.keyFunction.init(context);
    this.valueFunction.init(context);
  }
An operator that sends sends messages to an output {@link SystemStream} for repartitioning them.
samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java