Package org.apache.storm.trident.windowing

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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
InMemoryWindowsStoreFactory()

Method Summary

Modifier and Type	Method	Description
WindowsStore	create(Map<String,Object> topoConf)	Creates a window store.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemoryWindowsStoreFactory

public InMemoryWindowsStoreFactory()

Method Details

create

public WindowsStore create(Map<String,Object> topoConf)

Description copied from interface: WindowsStoreFactory

Creates a window store.

Specified by:

create in interface WindowsStoreFactory

Parameters:

topoConf - storm topology configuration passed in TridentProcessor.prepare(Map, TopologyContext, TridentContext)