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 ofInMemoryWindowsStore
which 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 sameinMemoryWindowsStore
instance 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 WindowsStore
create(Map<String,Object> topoConf)
Creates a window store.
-
-
-
Method Detail
-
create
public WindowsStore create(Map<String,Object> topoConf)
Description copied from interface:WindowsStoreFactory
Creates a window store.- Specified by:
create
in interfaceWindowsStoreFactory
- Parameters:
topoConf
- storm topology configuration passed inTridentProcessor.prepare(Map, TopologyContext, TridentContext)
-
-