public static interface MergingWindowProcessFunction.MergingContext<K,W extends Window> extends InternalWindowProcessFunction.Context<K,W>
Context
used for MergingWindowProcessFunction
.Modifier and Type | Method and Description |
---|---|
BiConsumerWithException<W,Collection<W>,Throwable> |
getWindowStateMergingConsumer()
Returns the consumer used to merge window state.
|
clearPreviousState, clearTrigger, clearWindowState, currentKey, currentProcessingTime, currentWatermark, deleteCleanupTimer, getPartitionedState, getShiftTimeZone, getWindowAccumulators, onMerge, setWindowAccumulators
BiConsumerWithException<W,Collection<W>,Throwable> getWindowStateMergingConsumer()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.