Package | Description |
---|---|
org.apache.storm.windowing |
Modifier and Type | Class and Description |
---|---|
class |
DefaultEvictionContext |
Modifier and Type | Field and Description |
---|---|
protected EvictionContext |
TimeEvictionPolicy.evictionContext |
Modifier and Type | Method and Description |
---|---|
EvictionContext |
WatermarkCountEvictionPolicy.getContext() |
EvictionContext |
TimeEvictionPolicy.getContext() |
EvictionContext |
CountEvictionPolicy.getContext() |
EvictionContext |
EvictionPolicy.getContext()
Returns the current context that is part of this eviction policy.
|
EvictionContext |
TimeEvictionPolicy.getState() |
Modifier and Type | Method and Description |
---|---|
void |
TimeEvictionPolicy.restoreState(EvictionContext state) |
void |
WatermarkCountEvictionPolicy.setContext(EvictionContext context) |
void |
TimeEvictionPolicy.setContext(EvictionContext context) |
void |
CountEvictionPolicy.setContext(EvictionContext context) |
void |
EvictionPolicy.setContext(EvictionContext context)
Sets a context in the eviction policy that can be used while evicting the events.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.