Class DataGeneratorContainer


  • @Internal
    public class DataGeneratorContainer
    extends Object
    Container class for wrapping a with its configuration options.
    • Method Detail

      • of

        public static DataGeneratorContainer of​(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator generator,
                                                org.apache.flink.configuration.ConfigOption<?>... options)
      • getGenerator

        public org.apache.flink.streaming.api.functions.source.datagen.DataGenerator getGenerator()
      • getOptions

        public Set<org.apache.flink.configuration.ConfigOption<?>> getOptions()