org.apache.flink.streaming.api.environment

Class StreamPipelineOptions

java.lang.Object

org.apache.flink.streaming.api.environment.StreamPipelineOptions

Deprecated.

This option class is deprecated in 1.20 and will be removed in 2.0.

@Deprecated
 @PublicEvolving
public class StreamPipelineOptions
extends Object

The configuration options for job execution. Those are stream specific options. See also PipelineOptions.

Field Summary

Fields

Modifier and Type

Field and Description

static 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 Summary

Constructors

Constructor and Description
StreamPipelineOptions() Deprecated.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TIME_CHARACTERISTIC

@Deprecated
public static final 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()

Deprecated.