Package com.streambase.sb.monitor

Class StatsUtil.StatEncoder

java.lang.Object

com.streambase.sb.monitor.StatsUtil.StatEncoder

Enclosing class:

com.streambase.sb.monitor.StatsUtil

public static class StatsUtil.StatEncoder
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	StatsUtil.StatEncoder.KeyType

Field Summary

Fields

Modifier and Type	Field	Description
protected KeyRegistry	keys

Constructor Summary

Constructors

Constructor	Description
StatEncoder(StatsUtil.What what, KeyRegistry keys)

Method Summary

Modifier and Type	Method	Description
Tuple	marshal(Tuple t, com.streambase.sb.monitor.StatTuplev3 data)	Put data in StatBuffer into the tuple; after marshaling, the stat buffer is recycled.
com.streambase.sb.monitor.StatTuplev3	newStatTuple()	Get a tuple from cache.
com.streambase.sb.monitor.StatTuplev3	newStatTuple(int cycle, long time)
void	recycle(com.streambase.sb.monitor.StatTuplev3 data)
com.streambase.sb.monitor.StatTuplev3	unmarshal(Tuple t)	Retrieve data from tuple and returns a StatBuffer

Methods inherited from class java.lang.Object

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

Field Details

keys

protected KeyRegistry keys

Constructor Details

StatEncoder

public StatEncoder(StatsUtil.What what,
 KeyRegistry keys)

Method Details

marshal

public Tuple marshal(Tuple t,
 com.streambase.sb.monitor.StatTuplev3 data)

Put data in StatBuffer into the tuple; after marshaling, the stat buffer is recycled.

Parameters:

t - is the destination

data - is the source

Returns:

the destination tuple

unmarshal

public com.streambase.sb.monitor.StatTuplev3 unmarshal(Tuple t)
                                                throws NullValueException,
TupleException

Retrieve data from tuple and returns a StatBuffer

Parameters:

t -

Returns:

a statistics tuple

Throws:

TupleException

NullValueException

newStatTuple

public com.streambase.sb.monitor.StatTuplev3 newStatTuple(int cycle,
 long time)

newStatTuple

public com.streambase.sb.monitor.StatTuplev3 newStatTuple()

Get a tuple from cache. It should be thread-safe

Returns:

a statistics tuple

recycle

public void recycle(com.streambase.sb.monitor.StatTuplev3 data)