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

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

All Implemented Interfaces:

IDataSinkService, IWireTarget

Direct Known Subclasses:

TimePersistor

public class ByteStreamPersistor
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

ByteStreamPersistor(ContributionManager manager)

Method Summary

boolean	acceptWireSource(IWireSource target)
DimensionSet	getDimensionSet()
protected java.lang.Class[]	getSupportedTypes()
void	setDataSet(DataSet ds)
void	store(byte[] bytes)

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

ByteStreamPersistor

public ByteStreamPersistor(ContributionManager manager)

Method Detail

store

public void store(byte[] bytes)
           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 ds)

Specified by:

setDataSet in interface IDataSinkService