Package org.apache.storm.blobstore
Class LocalFsBlobStoreSynchronizer
java.lang.Object
org.apache.storm.blobstore.LocalFsBlobStoreSynchronizer
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 SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeleteKeySetFromBlobStoreNotOnZookeeper(Set<String> keySetBlobStore, Set<String> keySetZookeeper) getKeySetToDownload(Set<String> blobStoreKeySet, Set<String> zookeeperKeySet) voidsetBlobStoreKeySet(Set<String> blobStoreKeySet) voidsetNimbusInfo(NimbusInfo nimbusInfo) voidsetZkClient(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) voidsetZookeeperKeySet(Set<String> zookeeperKeySet) voidvoidupdateKeySetForBlobStore(Set<String> keySetBlobStore) 
- 
Constructor Details- 
LocalFsBlobStoreSynchronizer
 
- 
- 
Method Details- 
setNimbusInfo
- 
setZkClientpublic void setZkClient(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient) 
- 
getBlobStoreKeySet
- 
setBlobStoreKeySet
- 
getZookeeperKeySet
- 
setZookeeperKeySet
- 
syncBlobspublic void syncBlobs()
- 
deleteKeySetFromBlobStoreNotOnZookeeperpublic void deleteKeySetFromBlobStoreNotOnZookeeper(Set<String> keySetBlobStore, Set<String> keySetZookeeper) throws Exception - Throws:
- Exception
 
- 
updateKeySetForBlobStore
- 
getKeySetToDownload
 
-