Class LocalFsBlobStoreSynchronizer

java.lang.Object
org.apache.storm.blobstore.LocalFsBlobStoreSynchronizer

public class LocalFsBlobStoreSynchronizer extends Object
Is called periodically and updates the nimbus with blobs based on the state stored inside the zookeeper for a non leader nimbus trying to be in sync with the operations performed on the leader nimbus.
  • Constructor Details

  • Method Details

    • setNimbusInfo

      public void setNimbusInfo(NimbusInfo nimbusInfo)
    • setZkClient

      public void setZkClient(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient)
    • getBlobStoreKeySet

      public Set<String> getBlobStoreKeySet()
    • setBlobStoreKeySet

      public void setBlobStoreKeySet(Set<String> blobStoreKeySet)
    • getZookeeperKeySet

      public Set<String> getZookeeperKeySet()
    • setZookeeperKeySet

      public void setZookeeperKeySet(Set<String> zookeeperKeySet)
    • syncBlobs

      public void syncBlobs()
    • deleteKeySetFromBlobStoreNotOnZookeeper

      public void deleteKeySetFromBlobStoreNotOnZookeeper(Set<String> keySetBlobStore, Set<String> keySetZookeeper) throws Exception
      Throws:
      Exception
    • updateKeySetForBlobStore

      public void updateKeySetForBlobStore(Set<String> keySetBlobStore)
    • getKeySetToDownload

      public Set<String> getKeySetToDownload(Set<String> blobStoreKeySet, Set<String> zookeeperKeySet)