Class InMemoryWindowsStoreFactory
java.lang.Object
org.apache.storm.trident.windowing.InMemoryWindowsStoreFactory
- All Implemented Interfaces:
Serializable,WindowsStoreFactory
InMemoryWindowsStoreFactory contains a single instance of
InMemoryWindowsStore which will be used for storing tuples and triggers
of the window. The same InMemoryWindowsStoreFactory instance is passed to WindowsStateUpdater, which removes successfully emitted
triggers from the same inMemoryWindowsStore instance in WindowsStateUpdater.updateState(WindowsState, List, TridentCollector).- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionCreates a window store.
-
Constructor Details
-
InMemoryWindowsStoreFactory
public InMemoryWindowsStoreFactory()
-
-
Method Details
-
create
Description copied from interface:WindowsStoreFactoryCreates a window store.- Specified by:
createin interfaceWindowsStoreFactory- Parameters:
topoConf- storm topology configuration passed inTridentProcessor.prepare(Map, TopologyContext, TridentContext)
-