Package | Description |
---|---|
org.apache.flink.streaming.api.windowing.evictors |
Modifier and Type | Method and Description |
---|---|
void |
TimeEvictor.evictAfter(Iterable<TimestampedValue<Object>> elements,
int size,
W window,
Evictor.EvictorContext ctx) |
void |
CountEvictor.evictAfter(Iterable<TimestampedValue<Object>> elements,
int size,
W window,
Evictor.EvictorContext ctx) |
void |
DeltaEvictor.evictAfter(Iterable<TimestampedValue<T>> elements,
int size,
W window,
Evictor.EvictorContext ctx) |
void |
Evictor.evictAfter(Iterable<TimestampedValue<T>> elements,
int size,
W window,
Evictor.EvictorContext evictorContext)
Optionally evicts elements.
|
void |
TimeEvictor.evictBefore(Iterable<TimestampedValue<Object>> elements,
int size,
W window,
Evictor.EvictorContext ctx) |
void |
CountEvictor.evictBefore(Iterable<TimestampedValue<Object>> elements,
int size,
W window,
Evictor.EvictorContext ctx) |
void |
DeltaEvictor.evictBefore(Iterable<TimestampedValue<T>> elements,
int size,
W window,
Evictor.EvictorContext ctx) |
void |
Evictor.evictBefore(Iterable<TimestampedValue<T>> elements,
int size,
W window,
Evictor.EvictorContext evictorContext)
Optionally evicts elements.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.