org.eclipse.cosmos.dc.sample.components.sink
Class StatisticalPersistor

java.lang.Object
  org.eclipse.cosmos.dc.common.api.impl.AbstractPersistor
      org.eclipse.cosmos.dc.sample.components.sink.StatisticalPersistor

All Implemented Interfaces:

IDataSinkService, IWireTarget

public class StatisticalPersistor
extends AbstractPersistor
implements IDataSinkService

Field Summary

Fields inherited from class org.eclipse.cosmos.dc.common.api.impl.AbstractPersistor

_proxy

Fields inherited from interface org.eclipse.cosmos.dc.common.api.IDataSinkService

DATA_FLOW_QNAME, DATA_KEY_QNAME, DATA_KEY_SET_QNAME, DATA_SOURCE_TYPE_QNAME, SINK_QNAME

Constructor Summary

StatisticalPersistor(ContributionManager manager, com.ibatis.sqlmap.client.SqlMapClient sqlMapper, DimensionSet dims, java.util.Map<java.lang.String,java.lang.String> keyMap)

Method Summary

boolean	acceptWireSource(IWireSource target)
DimensionSet	getDimensionSet()
protected java.lang.Class[]	getSupportedTypes()
void	setDataSet(DataSet dataset)
void	store(StatisticalTuple tuple)

Methods inherited from class org.eclipse.cosmos.dc.common.api.impl.AbstractPersistor

acceptType, getAcceptableTypes, getStoreMethod, getWireMethod, getWireSource, setWireMethod, setWireSource

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.cosmos.dc.common.api.IDataSinkService

acceptType, getStoreMethod

Methods inherited from interface org.eclipse.cosmos.dc.common.spi.IWireTarget

getAcceptableTypes, getWireMethod, getWireSource, setWireMethod, setWireSource

Constructor Detail

StatisticalPersistor

public StatisticalPersistor(ContributionManager manager,
                            com.ibatis.sqlmap.client.SqlMapClient sqlMapper,
                            DimensionSet dims,
                            java.util.Map<java.lang.String,java.lang.String> keyMap)

Method Detail

store

public void store(StatisticalTuple tuple)
           throws java.lang.Exception

Throws:

java.lang.Exception

getSupportedTypes

protected java.lang.Class[] getSupportedTypes()

Specified by:

getSupportedTypes in class AbstractPersistor

acceptWireSource

public boolean acceptWireSource(IWireSource target)
                         throws java.lang.Exception

Specified by:

acceptWireSource in class AbstractPersistor

Throws:

java.lang.Exception

getDimensionSet

public DimensionSet getDimensionSet()

Specified by:

getDimensionSet in interface IDataSinkService

setDataSet

public void setDataSet(DataSet dataset)

Specified by:

setDataSet in interface IDataSinkService