Class StreamPipelineOptions


  • @PublicEvolving
    public class StreamPipelineOptions
    extends Object
    The configuration options for job execution. Those are stream specific options. See also PipelineOptions.
    • Field Detail

      • TIME_CHARACTERISTIC

        @Deprecated
        public static final org.apache.flink.configuration.ConfigOption<TimeCharacteristic> TIME_CHARACTERISTIC
        Deprecated.
        In Flink 1.12 the default stream time characteristic has been changed to TimeCharacteristic.EventTime, thus you don't need to set this option for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please set PipelineOptions.AUTO_WATERMARK_INTERVAL to 0. If you are using TimeCharacteristic.IngestionTime, please manually set an appropriate WatermarkStrategy. If you are using generic "time window" operations (for example KeyedStream.timeWindow(org.apache.flink.streaming.api.windowing.time.Time) that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.
    • Constructor Detail

      • StreamPipelineOptions

        public StreamPipelineOptions()