Class InMemoryWindowsStore
- java.lang.Object
-
- org.apache.storm.trident.windowing.InMemoryWindowsStore
-
- All Implemented Interfaces:
Serializable,WindowsStore
public class InMemoryWindowsStore extends Object implements WindowsStore, Serializable
Inmemory store implementation ofWindowsStorewhich can be backed by persistent store.- See Also:
- Serialized Form
-
-
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
Constructors Constructor Description InMemoryWindowsStore()InMemoryWindowsStore(int maxSize, WindowsStore backingStore)Creates a new in-memory window store.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Objectget(String key)Iterable<Object>get(List<String> keys)Iterable<String>getAllKeys()voidput(String key, Object value)voidputAll(Collection<WindowsStore.Entry> entries)voidremove(String key)voidremoveAll(Collection<String> keys)voidshutdown()StringtoString()
-
-
-
Constructor Detail
-
InMemoryWindowsStore
public InMemoryWindowsStore()
-
InMemoryWindowsStore
public InMemoryWindowsStore(int maxSize, WindowsStore backingStore)Creates a new in-memory window store.- Parameters:
maxSize- maximum size of inmemory storebackingStore- backing store containing the entries
-
-
Method Detail
-
get
public Object get(String key)
- Specified by:
getin interfaceWindowsStore
-
getAllKeys
public Iterable<String> getAllKeys()
- Specified by:
getAllKeysin interfaceWindowsStore
-
put
public void put(String key, Object value)
- Specified by:
putin interfaceWindowsStore
-
putAll
public void putAll(Collection<WindowsStore.Entry> entries)
- Specified by:
putAllin interfaceWindowsStore
-
remove
public void remove(String key)
- Specified by:
removein interfaceWindowsStore
-
removeAll
public void removeAll(Collection<String> keys)
- Specified by:
removeAllin interfaceWindowsStore
-
shutdown
public void shutdown()
- Specified by:
shutdownin interfaceWindowsStore
-
-