Package org.apache.storm.blobstore

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)