Package | Description |
---|---|
org.apache.flink.streaming.api.functions | |
org.apache.flink.table.runtime.functions | |
org.apache.flink.table.runtime.operators.over |
Modifier and Type | Method and Description |
---|---|
void |
KeyedProcessFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<O> out)
Called when a timer set using
TimerService fires. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
KeyedProcessFunctionWithCleanupState.isProcessingTimeTimer(KeyedProcessFunction.OnTimerContext ctx) |
Modifier and Type | Method and Description |
---|---|
void |
ProcTimeRowsBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<RowData> out) |
void |
RowTimeRowsBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<RowData> out) |
void |
AbstractRowTimeUnboundedPrecedingOver.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<RowData> out) |
void |
ProcTimeRangeBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<RowData> out) |
void |
RowTimeRangeBoundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<RowData> out) |
void |
ProcTimeUnboundedPrecedingFunction.onTimer(long timestamp,
KeyedProcessFunction.OnTimerContext ctx,
Collector<RowData> out) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.