@Override
    public String getAccumulatorUpdater(ChainVariable inVar, String acc) {
      return myDownstreamCollector.getAccumulatorUpdater(new ChainVariable(myMapper.getResultType(), myMapper.getText()), acc);
    }
@Override
    public String getAccumulatorUpdater(ChainVariable inVar, String acc)