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 and Description
InMemoryWindowsStoreFactory()

Method Summary

Modifier and Type	Method and Description
WindowsStore	create(Map stormConf) Creates a window store

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryWindowsStoreFactory

public InMemoryWindowsStoreFactory()

Method Detail

create

public WindowsStore create(Map stormConf)

Description copied from interface: WindowsStoreFactory

Creates a window store

Specified by:

create in interface WindowsStoreFactory

Parameters:

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