code: @SuppressWarnings("rawtypes")
      @Override
      public storm.trident.spout.ITridentSpout.Emitter<Object> getEmitter(String txStateId, Map conf,
              TopologyContext context)
      {
          DrpcTridentEmitter emitter = null;
  
          try
          {
              emitter = this.emitterClassType.newInstance();
              emitter.initialize(conf, context, this.function);
          }
          catch (Exception ex)
          {
              logger.error("Emitter create failed.", ex);
          }
  
          return emitter;
      }
docs: {@inheritDoc}