Class InMemoryWindowsStore
java.lang.Object
org.apache.storm.trident.windowing.InMemoryWindowsStore
- All Implemented Interfaces:
Serializable,WindowsStore
Inmemory store implementation of
WindowsStore which can be backed by persistent store.- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.storm.trident.windowing.WindowsStore
WindowsStore.Entry -
Field Summary
Fields inherited from interface org.apache.storm.trident.windowing.WindowsStore
KEY_SEPARATOR -
Constructor Summary
ConstructorsConstructorDescriptionInMemoryWindowsStore(int maxSize, WindowsStore backingStore) Creates a new in-memory window store. -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidputAll(Collection<WindowsStore.Entry> entries) voidvoidremoveAll(Collection<String> keys) voidshutdown()toString()
-
Constructor Details
-
InMemoryWindowsStore
public InMemoryWindowsStore() -
InMemoryWindowsStore
Creates a new in-memory window store.- Parameters:
maxSize- maximum size of inmemory storebackingStore- backing store containing the entries
-
-
Method Details
-
get
- Specified by:
getin interfaceWindowsStore
-
get
- Specified by:
getin interfaceWindowsStore
-
getAllKeys
- Specified by:
getAllKeysin interfaceWindowsStore
-
put
- Specified by:
putin interfaceWindowsStore
-
putAll
- Specified by:
putAllin interfaceWindowsStore
-
remove
- Specified by:
removein interfaceWindowsStore
-
removeAll
- Specified by:
removeAllin interfaceWindowsStore
-
shutdown
public void shutdown()- Specified by:
shutdownin interfaceWindowsStore
-
toString
-