org.apache.storm.blobstore

Class BlobStoreUtils

java.lang.Object

org.apache.storm.blobstore.BlobStoreUtils

public class BlobStoreUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
BlobStoreUtils()

Method Summary

Modifier and Type	Method and Description
static String	applyUUIDToFileName(String fileName)
static void	createStateInZookeeper(Map conf, String key, NimbusInfo nimbusInfo)
static org.apache.curator.framework.CuratorFramework	createZKClient(Map conf, List<org.apache.zookeeper.data.ACL> defaultAcls)
static boolean	downloadMissingBlob(Map conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)
static boolean	downloadUpdatedBlob(Map conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)
static String	generateDependencyBlobKey(String key)
static String	getBlobStoreSubtree()
static List<String>	getKeyListFromBlobStore(BlobStore blobStore)
static int	getLatestSequenceNumber(List<String> stateInfoList)
static Set<NimbusInfo>	getNimbodesWithLatestSequenceNumberOfBlob(org.apache.curator.framework.CuratorFramework zkClient, String key)
static Subject	getNimbusSubject()
static BlobKeySequenceInfo	normalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo)
static void	updateKeyForBlobStore(Map conf, BlobStore blobStore, org.apache.curator.framework.CuratorFramework zkClient, String key, NimbusInfo nimbusDetails)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobStoreUtils

public BlobStoreUtils()

Method Detail

getBlobStoreSubtree

public static String getBlobStoreSubtree()

createZKClient

public static org.apache.curator.framework.CuratorFramework createZKClient(Map conf,
                                                                           List<org.apache.zookeeper.data.ACL> defaultAcls)

getNimbusSubject

public static Subject getNimbusSubject()

normalizeNimbusHostPortSequenceNumberInfo

public static BlobKeySequenceInfo normalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo)

getNimbodesWithLatestSequenceNumberOfBlob

public static Set<NimbusInfo> getNimbodesWithLatestSequenceNumberOfBlob(org.apache.curator.framework.CuratorFramework zkClient,
                                                                        String key)
                                                                 throws Exception

Throws:

Exception

getLatestSequenceNumber

public static int getLatestSequenceNumber(List<String> stateInfoList)

downloadMissingBlob

public static boolean downloadMissingBlob(Map conf,
                                          BlobStore blobStore,
                                          String key,
                                          Set<NimbusInfo> nimbusInfos)
                                   throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

downloadUpdatedBlob

public static boolean downloadUpdatedBlob(Map conf,
                                          BlobStore blobStore,
                                          String key,
                                          Set<NimbusInfo> nimbusInfos)
                                   throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

getKeyListFromBlobStore

public static List<String> getKeyListFromBlobStore(BlobStore blobStore)
                                            throws Exception

Throws:

Exception

createStateInZookeeper

public static void createStateInZookeeper(Map conf,
                                          String key,
                                          NimbusInfo nimbusInfo)
                                   throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

updateKeyForBlobStore

public static void updateKeyForBlobStore(Map conf,
                                         BlobStore blobStore,
                                         org.apache.curator.framework.CuratorFramework zkClient,
                                         String key,
                                         NimbusInfo nimbusDetails)

generateDependencyBlobKey

public static String generateDependencyBlobKey(String key)

applyUUIDToFileName

public static String applyUUIDToFileName(String fileName)