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

    All Methods Static Methods Concrete Methods
    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)`

    - ### 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.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`

    - #### getLatestSequenceNumber

          public static int getLatestSequenceNumber(List<String> stateInfoList)

    - #### 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`

    - #### updateKeyForBlobStore

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

Copyright © 2021 The Apache Software Foundation. All rights reserved.