org.apache.storm.blobstore

Class BlobSynchronizer

java.lang.Object

org.apache.storm.blobstore.BlobSynchronizer

public class BlobSynchronizer
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 Summary

Constructors

Constructor and Description
BlobSynchronizer(BlobStore blobStore, Map conf)

Method Summary

Modifier and Type	Method and Description
void	deleteKeySetFromBlobStoreNotOnZookeeper(Set<String> keySetBlobStore, Set<String> keySetZookeeper)
Set<String>	getBlobStoreKeySet()
Set<String>	getKeySetToDownload(Set<String> blobStoreKeySet, Set<String> zookeeperKeySet)
Set<String>	getZookeeperKeySet()
void	setBlobStoreKeySet(Set<String> blobStoreKeySet)
void	setNimbusInfo(NimbusInfo nimbusInfo)
void	setZkClient(org.apache.curator.framework.CuratorFramework zkClient)
void	setZookeeperKeySet(Set<String> zookeeperKeySet)
void	syncBlobs()
void	updateKeySetForBlobStore(Set<String> keySetBlobStore)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlobSynchronizer

public BlobSynchronizer(BlobStore blobStore,
                        Map conf)

Method Detail

setNimbusInfo

public void setNimbusInfo(NimbusInfo nimbusInfo)

setZookeeperKeySet

public void setZookeeperKeySet(Set<String> zookeeperKeySet)

setBlobStoreKeySet

public void setBlobStoreKeySet(Set<String> blobStoreKeySet)

setZkClient

public void setZkClient(org.apache.curator.framework.CuratorFramework zkClient)

getBlobStoreKeySet

public Set<String> getBlobStoreKeySet()

getZookeeperKeySet

public Set<String> getZookeeperKeySet()

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)