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
ConstructorDescriptionInMemoryWindowsStore
(int maxSize, WindowsStore backingStore) Creates a new in-memory window store. -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
putAll
(Collection<WindowsStore.Entry> entries) void
void
removeAll
(Collection<String> keys) void
shutdown()
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:
get
in interfaceWindowsStore
-
get
- Specified by:
get
in interfaceWindowsStore
-
getAllKeys
- Specified by:
getAllKeys
in interfaceWindowsStore
-
put
- Specified by:
put
in interfaceWindowsStore
-
putAll
- Specified by:
putAll
in interfaceWindowsStore
-
remove
- Specified by:
remove
in interfaceWindowsStore
-
removeAll
- Specified by:
removeAll
in interfaceWindowsStore
-
shutdown
public void shutdown()- Specified by:
shutdown
in interfaceWindowsStore
-
toString
-