Class UpsertTestConnectorOptions


  • @PublicEvolving
    public class UpsertTestConnectorOptions
    extends Object
    Options for the UpsertTestConnector.
    • Field Detail

      • OUTPUT_FILEPATH_OPTION

        public static final org.apache.flink.configuration.ConfigOption<String> OUTPUT_FILEPATH_OPTION
      • KEY_FORMAT_OPTION

        public static final org.apache.flink.configuration.ConfigOption<String> KEY_FORMAT_OPTION
      • VALUE_FORMAT_OPTION

        public static final org.apache.flink.configuration.ConfigOption<String> VALUE_FORMAT_OPTION
    • Constructor Detail

      • UpsertTestConnectorOptions

        public UpsertTestConnectorOptions()