Package | Description |
---|---|
org.apache.flink.streaming.api.functions | |
org.apache.flink.table.runtime.aggregate |
Modifier and Type | Method and Description |
---|---|
void |
ProcessFunction.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<O> out)
Called when a timer set using
TimerService fires. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ProcessFunctionWithCleanupState.isProcessingTimeTimer(ProcessFunction.OnTimerContext ctx) |
void |
RowTimeBoundedRangeOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRowsOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
ProcTimeBoundedRangeOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
RowTimeBoundedRowsOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
GroupAggProcessFunction.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
ProcTimeUnboundedOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out) |
void |
RowTimeUnboundedOver.onTimer(long timestamp,
ProcessFunction.OnTimerContext ctx,
Collector<CRow> out)
Called when a watermark arrived.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.