code: public void submitTopology(boolean isLocal)
      {
          if (logger.isInfoEnabled())
          {
              logger.info("isLocal=" + isLocal);
          }
  
          if (isLocal)
          {
              // ローカル環境で実行
              LocalCluster cluster = new LocalCluster();
              cluster.submitTopology(getTopologyName(), getConfig(), getBuilder().createTopology());
          }
          else
          {
              // 分散環境で実行
              try
              {
                  StormSubmitter.submitTopology(getTopologyName(), getConfig(),
                          getBuilder().createTopology());
              }
              catch (AlreadyAliveException ex)
              {
                  String logFormat = "Occur exception at Topology Submit. Skip Topology Submit. : TopologyName={0}";
                  String logMessage = MessageFormat.format(logFormat, getTopologyName());
                  logger.error(logMessage, ex);
              }
              catch (InvalidTopologyException ex)
              {
                  String logFormat = "Occur exception at Topology Submit. Skip Topology Submit. : TopologyName={0}";
                  String logMessage = MessageFormat.format(logFormat, getTopologyName());
                  logger.error(logMessage, ex);
              }
          }
      }
docs: Topologyを実行する。
  @param isLocal true:ローカルモード、false:分散モード