code: private static void setupStormCode(Map conf, String topologyId, String topologyRoot, Set<String> activeKeys)
              throws Exception {
          Map<String, String> blobKeysToLocation = getBlobKeysToLocation(topologyRoot, topologyId);
          for (Map.Entry<String, String> entry : blobKeysToLocation.entrySet()) {
              String key = entry.getKey();
              String location = entry.getValue();
              if (!activeKeys.contains(key)) {
                  blobStore.createBlob(key, new FileInputStream(location), new SettableBlobMeta());
                  if (isLocalBlobStore) {
                      int versionInfo = BlobStoreUtils.getVersionForKey(key, nimbusInfo, conf);
                      clusterState.setup_blobstore(key, nimbusInfo, versionInfo);
                  }
              }
          }
  
          System.out.println("Successfully create blobstore for topology " + topologyId);
      }
docs: create local topology files in blobstore and sync metadata to zk