Package | Description |
---|---|
org.apache.flink.streaming.api.windowing.evictors | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static <T> TimestampedValue<T> |
TimestampedValue.from(StreamRecord<T> streamRecord)
Creates a TimestampedValue from given
StreamRecord . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.