code: @SuppressWarnings("rawtypes")
      public static WorkerShutdown mk_worker(Map conf, IContext context, String topologyId, String supervisorId,
                                             int port, String workerId, String jarPath) throws Exception {
          StringBuilder sb = new StringBuilder();
          sb.append("topologyId:").append(topologyId).append(", ");
          sb.append("port:").append(port).append(", ");
          sb.append("workerId:").append(workerId).append(", ");
          sb.append("jarPath:").append(jarPath).append("\n");
  
          LOG.info("Begin to run worker:" + sb.toString());
          Worker w = new Worker(conf, context, topologyId, supervisorId, port, workerId, jarPath);
          //   w.redirectOutput();
  
          return w.execute();
      }
docs: create worker instance and run it
  
  @param conf         storm conf
  @param topologyId   topology id
  @param supervisorId supervisor iid
  @param port         worker port
  @param workerId     worker id
  @return WorkerShutDown
  @throws Exception