Package | Description |
---|---|
org.apache.flink.streaming.api.windowing.evictors |
Modifier and Type | Method and Description |
---|---|
static <T,W extends Window> |
DeltaEvictor.of(double threshold,
DeltaFunction<T> deltaFunction)
Creates a
DeltaEvictor from the given threshold and DeltaFunction . |
static <T,W extends Window> |
DeltaEvictor.of(double threshold,
DeltaFunction<T> deltaFunction,
boolean doEvictAfter)
Creates a
DeltaEvictor from the given threshold, DeltaFunction . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.