org.apache.storm.hbase.trident.windowing

Class HBaseWindowsStore

java.lang.Object

org.apache.storm.hbase.trident.windowing.HBaseWindowsStore

All Implemented Interfaces:

Serializable, WindowsStore

public class HBaseWindowsStore
extends Object
implements WindowsStore

This class stores entries into hbase instance of the given configuration.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.storm.trident.windowing.WindowsStore

WindowsStore.Entry

Field Summary

Fields

Modifier and Type	Field and Description
static String	UTF_8

Fields inherited from interface org.apache.storm.trident.windowing.WindowsStore

KEY_SEPARATOR

Constructor Summary

Constructors

Constructor and Description
HBaseWindowsStore(Map stormConf, org.apache.hadoop.conf.Configuration config, String tableName, byte[] family, byte[] qualifier)

Method Summary

Modifier and Type	Method and Description
Iterable<Object>	get(List<String> keys)
Object	get(String key)
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()

Methods inherited from class java.lang.Object

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

Field Detail

UTF_8

public static final String UTF_8

See Also:

Constant Field Values

Constructor Detail

HBaseWindowsStore

public HBaseWindowsStore(Map stormConf,
                         org.apache.hadoop.conf.Configuration config,
                         String tableName,
                         byte[] family,
                         byte[] qualifier)

Method Detail

get

public Object get(String key)

Specified by:

get in interface WindowsStore

get

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

Specified by:

get in interface WindowsStore

getAllKeys

public Iterable<String> getAllKeys()

Specified by:

getAllKeys in interface WindowsStore

put

public void put(String key,
                Object value)

Specified by:

put in interface WindowsStore

putAll

public void putAll(Collection<WindowsStore.Entry> entries)

Specified by:

putAll in interface WindowsStore

remove

public void remove(String key)

Specified by:

remove in interface WindowsStore

removeAll

public void removeAll(Collection<String> keys)

Specified by:

removeAll in interface WindowsStore

shutdown

public void shutdown()

Specified by:

shutdown in interface WindowsStore