Package org.apache.storm.blobstore
Class BlobStoreUtils
java.lang.Object
org.apache.storm.blobstore.BlobStoreUtils
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic 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 StringgetKeyListFromBlobStore(BlobStore blobStore) static intgetLatestSequenceNumber(List<String> stateInfoList) static Set<NimbusInfo>getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key) static Subjectstatic 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) 
- 
Constructor Details- 
BlobStoreUtilspublic BlobStoreUtils()
 
- 
- 
Method Details- 
getBlobStoreSubtree
- 
createZKClientpublic static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework createZKClient(Map<String, Object> conf, DaemonType type) 
- 
getNimbusSubject
- 
normalizeNimbusHostPortSequenceNumberInfopublic static BlobKeySequenceInfo normalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo) 
- 
getNimbodesWithLatestSequenceNumberOfBlobpublic static Set<NimbusInfo> getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key) throws Exception - Throws:
- Exception
 
- 
getLatestSequenceNumber
- 
downloadMissingBlobpublic 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
 
- 
downloadUpdatedBlobpublic 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- Throws:
- Exception
 
- 
createStateInZookeeperpublic 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
 
- 
updateKeyForBlobStore
 
-