stream.data.storage

Class Store<T extends Serializable>

java.lang.Object

stream.AbstractProcessor

stream.data.storage.Store<T>

Type Parameters:

T -

All Implemented Interfaces:

DataService<T>, Processor, Service, StatefulProcessor

Direct Known Subclasses:

StoreList

public abstract class Store<T extends Serializable>
extends AbstractProcessor
implements DataService<T>

Author:

Hendrik Blom

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	capacity
protected Map<String,T>	data
protected String[]	keys
(package private) static org.slf4j.Logger	log

Fields inherited from class stream.AbstractProcessor

context

Constructor Summary

Constructors

Constructor and Description
Store()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	addData(String[] keys, Data item)
Integer	getCapacity()
T	getData(String key)
String[]	getKeys()
void	init(ProcessContext ctx)
Data	process(Data input)
void	reset()
void	setCapacity(Integer capacity)
void	setKeys(String[] keys)

Methods inherited from class stream.AbstractProcessor

finish, resetState

Methods inherited from class java.lang.Object

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

Field Detail

log

static org.slf4j.Logger log

keys

protected String[] keys

capacity

protected Integer capacity

data

protected Map<String,T extends Serializable> data

Constructor Detail

Store

public Store()

Method Detail

getData

public T getData(String key)

Specified by:

getData in interface DataService<T extends Serializable>

getKeys

public String[] getKeys()

setKeys

public void setKeys(String[] keys)

getCapacity

public Integer getCapacity()

setCapacity

public void setCapacity(Integer capacity)

init

public void init(ProcessContext ctx)
          throws Exception

Specified by:

init in interface StatefulProcessor

Overrides:

init in class AbstractProcessor

Throws:

Exception

addData

protected abstract void addData(String[] keys,
           Data item)

process

public Data process(Data input)

Specified by:

process in interface Processor

reset

public void reset()
           throws Exception

Specified by:

reset in interface Service

Throws:

Exception