code: @SuppressWarnings("rawtypes")
      @Override
      public storm.trident.spout.ITridentSpout.BatchCoordinator<Object> getCoordinator(
              String txStateId, Map conf, TopologyContext context)
      {
          return new DrpcTridentCoodinator();
      }
docs: {@inheritDoc}