Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
Class and Description |
---|
TimerService
Interface for working with time and timers.
|
Class and Description |
---|
TimerService
Interface for working with time and timers.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
TimeCharacteristic
Deprecated.
In Flink 1.12 the default stream time characteristic has been changed to
TimeCharacteristic.EventTime , thus you don't need to call this method 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 use ExecutionConfig.setAutoWatermarkInterval(long) . 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. |
TimeDomain
TimeDomain specifies whether a firing timer is based on event time or processing time. |
TimerService
Interface for working with time and timers.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
TimeCharacteristic
Deprecated.
In Flink 1.12 the default stream time characteristic has been changed to
TimeCharacteristic.EventTime , thus you don't need to call this method 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 use ExecutionConfig.setAutoWatermarkInterval(long) . 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. |
Class and Description |
---|
TimeDomain
TimeDomain specifies whether a firing timer is based on event time or processing time. |
TimerService
Interface for working with time and timers.
|
Class and Description |
---|
TimeDomain
TimeDomain specifies whether a firing timer is based on event time or processing time. |
TimerService
Interface for working with time and timers.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
TimeCharacteristic
Deprecated.
In Flink 1.12 the default stream time characteristic has been changed to
TimeCharacteristic.EventTime , thus you don't need to call this method 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 use ExecutionConfig.setAutoWatermarkInterval(long) . 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. |
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
TimeCharacteristic
Deprecated.
In Flink 1.12 the default stream time characteristic has been changed to
TimeCharacteristic.EventTime , thus you don't need to call this method 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 use ExecutionConfig.setAutoWatermarkInterval(long) . 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. |
Class and Description |
---|
TimeDomain
TimeDomain specifies whether a firing timer is based on event time or processing time. |
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
Class and Description |
---|
CheckpointingMode
The checkpointing mode defines what consistency guarantees the system gives in the presence of
failures.
|
TimeCharacteristic
Deprecated.
In Flink 1.12 the default stream time characteristic has been changed to
TimeCharacteristic.EventTime , thus you don't need to call this method 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 use ExecutionConfig.setAutoWatermarkInterval(long) . 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. |
Class and Description |
---|
TimerService
Interface for working with time and timers.
|
Class and Description |
---|
TimerService
Interface for working with time and timers.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.