public class BlobStoreUtils extends Object
Constructor and Description |
---|
BlobStoreUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
createStateInZookeeper(Map<String,Object> conf,
String key,
NimbusInfo nimbusInfo) |
static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework |
createZKClient(Map<String,Object> conf,
DaemonType type) |
static boolean |
downloadMissingBlob(Map<String,Object> conf,
BlobStore blobStore,
String key,
Set<NimbusInfo> nimbusInfos) |
static boolean |
downloadUpdatedBlob(Map<String,Object> conf,
BlobStore blobStore,
String key,
Set<NimbusInfo> nimbusInfos) |
static String |
getBlobStoreSubtree() |
static List<String> |
getKeyListFromBlobStore(BlobStore blobStore) |
static int |
getLatestSequenceNumber(List<String> stateInfoList) |
static Set<NimbusInfo> |
getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient,
String key) |
static Subject |
getNimbusSubject() |
static BlobKeySequenceInfo |
normalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo) |
static void |
updateKeyForBlobStore(Map<String,Object> conf,
BlobStore blobStore,
org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient,
String key,
NimbusInfo nimbusDetails) |
public static String getBlobStoreSubtree()
public static org.apache.storm.shade.org.apache.curator.framework.CuratorFramework createZKClient(Map<String,Object> conf, DaemonType type)
public static Subject getNimbusSubject()
public static BlobKeySequenceInfo normalizeNimbusHostPortSequenceNumberInfo(String nimbusSeqNumberInfo)
public static Set<NimbusInfo> getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key) throws Exception
Exception
public static boolean downloadMissingBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportException
public static boolean downloadUpdatedBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos) throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportException
public static List<String> getKeyListFromBlobStore(BlobStore blobStore) throws Exception
Exception
public static void createStateInZookeeper(Map<String,Object> conf, String key, NimbusInfo nimbusInfo) throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportException
Copyright © 2022 The Apache Software Foundation. All rights reserved.