org.eclipse.cosmos.dc.sample.components.sink.cbe
Class CBERDBSink

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

All Implemented Interfaces:

IDataSinkService, IWireTarget

public class CBERDBSink
extends AbstractPersistor

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

CBERDBSink(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 ds)
void	store(org.eclipse.hyades.logging.events.cbe.CommonBaseEvent event)

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

Constructor Detail

CBERDBSink

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

Method Detail

acceptWireSource

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

Specified by:

acceptWireSource in class AbstractPersistor

Throws:

java.lang.Exception

getSupportedTypes

protected java.lang.Class[] getSupportedTypes()

Specified by:

getSupportedTypes in class AbstractPersistor

store

public void store(org.eclipse.hyades.logging.events.cbe.CommonBaseEvent event)
           throws java.lang.Exception

Throws:

java.lang.Exception

getDimensionSet

public DimensionSet getDimensionSet()

setDataSet

public void setDataSet(DataSet ds)