Package org.apache.storm.blobstore
Class BlobStoreUtils
- java.lang.Object
-
- org.apache.storm.blobstore.BlobStoreUtils
-
public class BlobStoreUtils extends Object
-
-
Constructor Summary
Constructors Constructor Description BlobStoreUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidcreateStateInZookeeper(Map<String,Object> conf, String key, NimbusInfo nimbusInfo)static org.apache.storm.shade.org.apache.curator.framework.CuratorFrameworkcreateZKClient(Map<String,Object> conf, DaemonType type)static booleandownloadMissingBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)static booleandownloadUpdatedBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)static StringgetBlobStoreSubtree()static List<String>getKeyListFromBlobStore(BlobStore blobStore)static intgetLatestSequenceNumber(List<String> stateInfoList)static Set<NimbusInfo>getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key)static SubjectgetNimbusSubject()static BlobKeySequenceInfonormalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo)static voidupdateKeyForBlobStore(Map<String,Object> conf, BlobStore blobStore, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key, NimbusInfo nimbusDetails)
-
-
-
Method Detail
-
getBlobStoreSubtree
public static String getBlobStoreSubtree()
-
createZKClient
public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework createZKClient(Map<String,Object> conf, DaemonType type)
-
getNimbusSubject
public static Subject getNimbusSubject()
-
normalizeNimbusHostPortSequenceNumberInfo
public static BlobKeySequenceInfo normalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo)
-
getNimbodesWithLatestSequenceNumberOfBlob
public static Set<NimbusInfo> getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key) throws Exception
- Throws:
Exception
-
downloadMissingBlob
public static boolean downloadMissingBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) throws org.apache.storm.thrift.transport.TTransportException
- Throws:
org.apache.storm.thrift.transport.TTransportException
-
downloadUpdatedBlob
public static boolean downloadUpdatedBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) throws org.apache.storm.thrift.transport.TTransportException
- Throws:
org.apache.storm.thrift.transport.TTransportException
-
getKeyListFromBlobStore
public static List<String> getKeyListFromBlobStore(BlobStore blobStore) throws Exception
- Throws:
Exception
-
createStateInZookeeper
public static void createStateInZookeeper(Map<String,Object> conf, String key, NimbusInfo nimbusInfo) throws org.apache.storm.thrift.transport.TTransportException
- Throws:
org.apache.storm.thrift.transport.TTransportException
-
-