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);
    }
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 ) ; }
create local topology files in blobstore and sync metadata to zk