Package | Description |
---|---|
org.apache.flink.table.runtime.operators.window.triggers |
Modifier and Type | Method and Description |
---|---|
void |
ProcessingTimeTriggers.AfterFirstElementPeriodic.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
ProcessingTimeTriggers.AfterEndOfWindow.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
ProcessingTimeTriggers.AfterEndOfWindowNoLate.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
ElementTriggers.EveryElement.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
ElementTriggers.CountElement.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
EventTimeTriggers.AfterEndOfWindow.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
EventTimeTriggers.AfterEndOfWindowEarlyAndLate.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
EventTimeTriggers.AfterEndOfWindowNoLate.onMerge(W window,
Trigger.OnMergeContext mergeContext) |
void |
Trigger.onMerge(W window,
Trigger.OnMergeContext mergeContext)
Called when several windows have been merged into one window by the
WindowAssigner . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.