public class WindowManager.AggregationWindowCollector extends java.lang.Object implements WindowCollector, java.lang.Iterable<AggregateWindow>
| Modifier and Type | Field and Description |
|---|---|
private java.util.List<AggregateWindow> |
aggregationStores |
| Constructor and Description |
|---|
AggregationWindowCollector() |
| Modifier and Type | Method and Description |
|---|---|
(package private) boolean |
isEmpty() |
@NotNull java.util.Iterator<AggregateWindow> |
iterator() |
void |
trigger(long start,
long end) |
private final java.util.List<AggregateWindow> aggregationStores
public void trigger(long start,
long end)
trigger in interface WindowCollector@NotNull public @NotNull java.util.Iterator<AggregateWindow> iterator()
iterator in interface java.lang.Iterable<AggregateWindow>boolean isEmpty()