Enum CreateDisposition

java.lang.Object
java.lang.Enum<CreateDisposition>
io.github.flink.gcp.connector.pubsub.sink.CreateDisposition
All Implemented Interfaces:
Serializable, Comparable<CreateDisposition>, java.lang.constant.Constable

@Public public enum CreateDisposition extends Enum<CreateDisposition>
Whether the sink may create destination topics that do not exist.

toString() returns the hyphenated spelling rather than the constant name, because that spelling is what a SQL WITH clause is written in: Flink resolves an enum ConfigOption by matching the configured value against toString(), case-insensitively and with no other normalization. Flink's own DeliveryGuarantee carries its option spelling the same way.

  • Enum Constant Details

    • CREATE_IF_NEEDED

      public static final CreateDisposition CREATE_IF_NEEDED
      Create the destination topic with default topic settings when it does not exist.
    • CREATE_NEVER

      public static final CreateDisposition CREATE_NEVER
      Never create destination topics; publishing to a missing topic fails.
  • Method Details

    • values

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

      public static CreateDisposition valueOf(String name)
      Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (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 type has no constant with the specified name
      NullPointerException - if the argument is null
    • toString

      public String toString()
      Overrides:
      toString in class Enum<CreateDisposition>