Class InMemoryWindowsStoreFactory
- java.lang.Object
-
- org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory
-
- All Implemented Interfaces:
Serializable,WindowsStoreFactory
public class InMemoryWindowsStoreFactory extends Object implements WindowsStoreFactory
InMemoryWindowsStoreFactory contains a single instance ofInMemoryWindowsStorewhich will be used for storing tuples and triggers of the window. The same InMemoryWindowsStoreFactory instance is passed toWindowsStateUpdater, which removes successfully emitted triggers from the sameinMemoryWindowsStoreinstance inWindowsStateUpdater.updateState(WindowsState, List, TridentCollector).- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description InMemoryWindowsStoreFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description WindowsStorecreate(Map<String,Object> topoConf)Creates a window store.
-
-
-
Method Detail
-
create
public WindowsStore create(Map<String,Object> topoConf)
Description copied from interface:WindowsStoreFactoryCreates a window store.- Specified by:
createin interfaceWindowsStoreFactory- Parameters:
topoConf- storm topology configuration passed inTridentProcessor.prepare(Map, TopologyContext, TridentContext)
-
-