Package org.apache.storm.trident.windowing

Interface WindowsStore

All Superinterfaces:

Serializable

All Known Implementing Classes:

InMemoryWindowsStore

public interface WindowsStore
extends Serializable

Store for storing window related entities like windowed tuples, triggers etc. WindowKryoSerializer can be used for kryo serialization/deserialization of keys and values.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	WindowsStore.Entry	This class wraps key and value objects which can be passed to putAll method.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	KEY_SEPARATOR	This can be used as a separator while generating a key from sequence of strings.

Method Summary

Modifier and Type	Method	Description
Object	get(String key)
Iterable<Object>	get(List<String> keys)
Iterable<String>	getAllKeys()
void	put(String key, Object value)
void	putAll(Collection<WindowsStore.Entry> entries)
void	remove(String key)
void	removeAll(Collection<String> keys)
void	shutdown()

Field Details

KEY_SEPARATOR

static final String KEY_SEPARATOR

This can be used as a separator while generating a key from sequence of strings.

See Also:

• Constant Field Values

Method Details

get

Object get(String key)

get

Iterable<Object> get(List<String> keys)

getAllKeys

Iterable<String> getAllKeys()

put

void put(String key,
 Object value)

putAll

void putAll(Collection<WindowsStore.Entry> entries)

remove

void remove(String key)

removeAll

void removeAll(Collection<String> keys)

shutdown

void shutdown()