public static interface Trigger.OnMergeContext extends Trigger.TriggerContext
Trigger.TriggerContext
that is given to Trigger.onMerge(Window,
OnMergeContext)
.Modifier and Type | Method and Description |
---|---|
<S extends MergingState<?,?>> |
mergePartitionedState(StateDescriptor<S,?> stateDescriptor) |
deleteEventTimeTimer, deleteProcessingTimeTimer, getCurrentProcessingTime, getCurrentWatermark, getMetricGroup, getPartitionedState, getShiftTimeZone, registerEventTimeTimer, registerProcessingTimeTimer
<S extends MergingState<?,?>> void mergePartitionedState(StateDescriptor<S,?> stateDescriptor)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.