mxm commented on code in PR #20953:
URL: https://github.com/apache/flink/pull/20953#discussion_r990068651
##########
flink-core/src/main/java/org/apache/flink/configuration/ConfigOptions.java:
##########
@@ -270,7 +283,33 @@ public final ConfigOption<List<E>> defaultValues(E...
values) {
* @return The config option without a default value.
*/
public ConfigOption<List<E>> noDefaultValue() {
- return new ConfigOption<>(key, clazz,
ConfigOption.EMPTY_DESCRIPTION, null, true);
+ return new ConfigOption<>(key, clazz,
ConfigOption.EMPTY_DESCRIPTION, null, LIST);
+ }
+ }
+
+ /** Builder for map type {@link ConfigOption} with a value type V. */
+ public static class MapConfigOptionBuilder<V> {
+ private final String key;
+ private final Class<V> clazz;
+
+ MapConfigOptionBuilder(String key, Class<V> clazz) {
+ this.key = key;
+ this.clazz = clazz;
+ }
+
+ /** Defines that the option's type should be a list of previously
defined atomic type. */
+ @SuppressWarnings("rawtypes")
Review Comment:
The compiler doesn't let me.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
