Modifier and Type | Method and Description |
---|---|
static TimeCharacteristic |
TimeCharacteristic.valueOf(String name)
Deprecated.
Returns the enum constant of this type with the specified name.
|
static TimeCharacteristic[] |
TimeCharacteristic.values()
Deprecated.
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<TimeCharacteristic> |
StreamPipelineOptions.TIME_CHARACTERISTIC |
Modifier and Type | Method and Description |
---|---|
TimeCharacteristic |
StreamExecutionEnvironment.getStreamTimeCharacteristic()
Deprecated.
See
StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic) for deprecation
notice. |
Modifier and Type | Method and Description |
---|---|
void |
StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic characteristic)
Deprecated.
In Flink 1.12 the default stream time characteristic has been changed to
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 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. |
Modifier and Type | Field and Description |
---|---|
static TimeCharacteristic |
StreamGraphGenerator.DEFAULT_TIME_CHARACTERISTIC |
Modifier and Type | Method and Description |
---|---|
TimeCharacteristic |
StreamGraph.getTimeCharacteristic() |
TimeCharacteristic |
StreamConfig.getTimeCharacteristic() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setTimeCharacteristic(TimeCharacteristic timeCharacteristic) |
StreamGraphGenerator |
StreamGraphGenerator.setTimeCharacteristic(TimeCharacteristic timeCharacteristic) |
void |
StreamConfig.setTimeCharacteristic(TimeCharacteristic characteristic) |
Modifier and Type | Method and Description |
---|---|
static <OUT> SourceFunction.SourceContext<OUT> |
StreamSourceContexts.getSourceContext(TimeCharacteristic timeCharacteristic,
ProcessingTimeService processingTimeService,
Object checkpointLock,
Output<StreamRecord<OUT>> output,
long watermarkInterval,
long idleTimeout,
boolean emitProgressiveWatermarks)
Depending on the
TimeCharacteristic , this method will return the adequate SourceFunction.SourceContext . |
Modifier and Type | Method and Description |
---|---|
TimeCharacteristic |
DummyStreamExecutionEnvironment.getStreamTimeCharacteristic() |
Modifier and Type | Method and Description |
---|---|
void |
DummyStreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic characteristic) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.