code: @SuppressWarnings("unchecked")
    public ForkOperator getForkOperator() {
      try {
        ForkOperator fork =
            ForkOperator.class.cast(Class.forName(this.taskState.getProp(ConfigurationKeys.FORK_OPERATOR_CLASS_KEY,
                ConfigurationKeys.DEFAULT_FORK_OPERATOR_CLASS)).newInstance());
        return new InstrumentedForkOperatorDecorator<>(fork);
      } catch (ClassNotFoundException cnfe) {
        throw new RuntimeException(cnfe);
      } catch (InstantiationException ie) {
        throw new RuntimeException(ie);
      } catch (IllegalAccessException iae) {
        throw new RuntimeException(iae);
      }
    }
docs: Get the {@link ForkOperator} to be applied to converted input schema and data record.
  
  @return {@link ForkOperator} to be used or <code>null</code> if none is specified