Package | Description |
---|---|
org.apache.flink.streaming.api | |
org.apache.flink.streaming.api.functions | |
org.apache.flink.streaming.api.functions.co | |
org.apache.flink.streaming.api.utils.input |
Modifier and Type | Method and Description |
---|---|
static TimeDomain |
TimeDomain.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TimeDomain[] |
TimeDomain.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
abstract TimeDomain |
ProcessFunction.OnTimerContext.timeDomain()
The
TimeDomain of the firing timer. |
abstract TimeDomain |
KeyedProcessFunction.OnTimerContext.timeDomain()
The
TimeDomain of the firing timer. |
Modifier and Type | Method and Description |
---|---|
abstract TimeDomain |
KeyedBroadcastProcessFunction.OnTimerContext.timeDomain()
The
TimeDomain of the firing timer, i.e. |
abstract TimeDomain |
CoProcessFunction.OnTimerContext.timeDomain()
The
TimeDomain of the firing timer. |
abstract TimeDomain |
KeyedCoProcessFunction.OnTimerContext.timeDomain()
The
TimeDomain of the firing timer. |
Modifier and Type | Method and Description |
---|---|
Row |
KeyedTwoInputWithTimerRowFactory.fromTimer(TimeDomain timeDomain,
long timestamp,
long watermark,
Row key,
byte[] encodedNamespace) |
Row |
KeyedInputWithTimerRowFactory.fromTimer(TimeDomain timeDomain,
long timestamp,
long watermark,
Row key,
byte[] encodedNamespace) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.