public abstract class AbstractSource extends SystemComponent implements Source
SystemComponent
implementing characteristics of a Source
for it offers data.Constructor and Description |
---|
AbstractSource(LifeCycleManager manager,
java.util.HashMap<java.lang.String,java.lang.String> configuration)
Creates a new
AbstractSource . |
Modifier and Type | Method and Description |
---|---|
ConnectorSource |
getSourceConnector()
Returns the
Source 's ConnectorSource . |
void |
initConnector()
Initiates a
SystemComponent 's Connector s. |
protected void |
writeOutput(DataEntry entry)
Offers data to all dispatched
Sink s. |
configure, configureComponent, disableMeasuring, enableMeasuring, getLifeCycleManager, getState, isReadyToMeasure, measure, measureComponent, stop, stopComponent, train, trainComponent
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getOutputDescription
public AbstractSource(LifeCycleManager manager, java.util.HashMap<java.lang.String,java.lang.String> configuration) throws InstantiationException
AbstractSource
. Requires a LifeCycleManager
to
register itself to in order to be managed (that is controlled in its
life-cycle) and a HashMap
containing information about the
source's configuration.manager
- LifeCycleManager
the source's will register itself to.configuration
- HashMap
containing information about the source's
configuration.InstantiationException
- if given configuration or manager are not valid.public void initConnector()
SystemComponent
SystemComponent
's Connector
s.initConnector
in class SystemComponent
public ConnectorSource getSourceConnector()
Source
Source
's ConnectorSource
.getSourceConnector
in interface Source
Source
's ConnectorSource
.