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 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: