pyflink.datastream.stream_execution_environment.StreamExecutionEnvironment.set_stream_time_characteristic#
- StreamExecutionEnvironment.set_stream_time_characteristic(characteristic: pyflink.datastream.time_characteristic.TimeCharacteristic)[source]#
Sets the time characteristic for all streams create from this environment, e.g., processing time, event time, or ingestion time.
If you set the characteristic to IngestionTime of EventTime this will set a default watermark update interval of 200 ms. If this is not applicable for your application you should change it using
pyflink.common.ExecutionConfig.set_auto_watermark_interval()
.Example:
>>> env.set_stream_time_characteristic(TimeCharacteristic.EventTime)
- Parameters
characteristic – The time characteristic, which could be
TimeCharacteristic.ProcessingTime
,TimeCharacteristic.IngestionTime
,TimeCharacteristic.EventTime
.