Enum Class PulsarAdapterUtil

java.lang.Object
java.lang.Enum<PulsarAdapterUtil>
io.nosqlbench.adapter.pulsar.util.PulsarAdapterUtil
All Implemented Interfaces:
Serializable, Comparable<PulsarAdapterUtil>, Constable
public enum PulsarAdapterUtil extends Enum<PulsarAdapterUtil>

  • Field Details

  • Method Details

    • values

      public static PulsarAdapterUtil[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared

    • valueOf

      public static PulsarAdapterUtil valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)
      Parameters:
      name - the name of the enum constant to be returned.
      Returns:
      the enum constant with the specified name
      Throws:
      IllegalArgumentException - if this enum class has no constant with the specified name
      NullPointerException - if the argument is null

    • isValidPulsarApiType

      public static boolean isValidPulsarApiType(String param)

    • isValidConfCategory

      public static boolean isValidConfCategory(String item)

    • getValidCompressionTypeList

      public static String getValidCompressionTypeList()

    • isCustomConsumerConfItem

      public static boolean isCustomConsumerConfItem(String item)

    • isValidSubscriptionType

      public static boolean isValidSubscriptionType(String item)

    • getValidSubscriptionTypeList

      public static String getValidSubscriptionTypeList()

    • getValidSubscriptionInitialPositionList

      public static String getValidSubscriptionInitialPositionList()

    • getValidRegexSubscriptionModeList

      public static String getValidRegexSubscriptionModeList()

    • isValideReaderStartPosition

      public static boolean isValideReaderStartPosition(String item)

    • isPrimitiveSchemaTypeStr

      public static boolean isPrimitiveSchemaTypeStr(String typeStr)
      ////

    • getPrimitiveTypeSchema

      public static org.apache.pulsar.client.api.Schema<?> getPrimitiveTypeSchema(String typeStr)

    • isAvroSchemaTypeStr

      public static boolean isAvroSchemaTypeStr(String typeStr)
      ////

    • isAutoConsumeSchemaTypeStr

      public static boolean isAutoConsumeSchemaTypeStr(String typeStr)

    • getAvroSchema

      public static org.apache.pulsar.client.api.Schema<?> getAvroSchema(String typeStr, String definitionStr)

    • convertJsonToMap

      public static Map<String,String> convertJsonToMap(String jsonStr) throws IOException
      Throws:
      IOException

    • getFullNamespaceName

      public static String getFullNamespaceName(String topicUri)
      ////