Uses of Interface
de.iip_ecosphere.platform.services.environment.DataIngestor

Packages that use DataIngestor

Package	Description
de.iip_ecosphere.platform.services.environment	Implementation.
de.iip_ecosphere.platform.services.environment.services	Generic services.

Uses of DataIngestor in de.iip_ecosphere.platform.services.environment

Classes in de.iip_ecosphere.platform.services.environment that implement DataIngestor

Modifier and Type	Class	Description
protected static class	AbstractPythonProcessService.SyncDataIngestor<D>	Ingestor implementation for synchronous processing.

Fields in de.iip_ecosphere.platform.services.environment declared as DataIngestor

Modifier and Type	Field	Description
private DataIngestor<T>	GenericMultiTypeServiceImpl.OutTypeInfo.ingestor

Fields in de.iip_ecosphere.platform.services.environment with type parameters of type DataIngestor

Modifier and Type	Field	Description
private List<DataIngestor<T>>	DataIngestors.ingestors

Methods in de.iip_ecosphere.platform.services.environment that return DataIngestor

Modifier and Type	Method	Description
protected DataIngestor<T>	GenericMultiTypeServiceImpl.OutTypeInfo.getIngestor()	Returns the associated ingestor.
DataIngestor<T>	GenericMultiTypeServiceImpl.OutTypeInfo.validateAndGetIngestor(String typeName)	Validates the associated ingestor and returns it.

Methods in de.iip_ecosphere.platform.services.environment with parameters of type DataIngestor

Modifier and Type	Method	Description
<O> void	AbstractDelegatingMultiService.attachIngestor(Class<O> outCls, String outTypeName, DataIngestor<O> ingestor)
<P> void	AbstractProcessService.attachIngestor(Class<P> outCls, DataIngestor<P> ingestor)	Attaches an asynchronous result data ingestor as callback.
<O> void	AbstractPythonProcessService.attachIngestor(Class<O> outCls, String outTypeName, DataIngestor<O> ingestor)
void	DataIngestors.attachIngestor(DataIngestor<T> ingestor)	Attaches an ingestor.
<O> void	GenericMultiTypeService.attachIngestor(Class<O> outCls, String outTypeName, DataIngestor<O> ingestor)	Attaches an asynchronous result data ingestor.
<O> void	GenericMultiTypeServiceImpl.attachIngestor(Class<O> outCls, String outTypeName, DataIngestor<O> ingestor)	Attaches an asynchronous result data ingestor.

Uses of DataIngestor in de.iip_ecosphere.platform.services.environment.services

Fields in de.iip_ecosphere.platform.services.environment.services declared as DataIngestor

Modifier and Type	Field	Description
private DataIngestor<D>	FixedRateSource.ingestor

Methods in de.iip_ecosphere.platform.services.environment.services that return DataIngestor

Modifier and Type	Method	Description
static <D> DataIngestor<D>	FixedRateSource.noIngestor()	Creates a no-ingestor that ignores data.

Methods in de.iip_ecosphere.platform.services.environment.services with parameters of type DataIngestor

Modifier and Type	Method	Description
protected void	FixedRateSource.setIngestor(DataIngestor<D> ingestor)	Changes the ingestor.

Constructors in de.iip_ecosphere.platform.services.environment.services with parameters of type DataIngestor

Modifier	Constructor	Description
	FixedRateSource(Supplier<D> dataCreator, FixedRateSource.FixedRateParams params, DataIngestor<D> ingestor, Supplier<ServiceState> stateSupplier)	Creates a fixed-rate source.
	TransportFixedRateSource(Supplier<D> dataCreator, FixedRateSource.TransportFixedRateSource.TransportFixedRateParams params, DataIngestor<D> ingestor, Supplier<ServiceState> stateSupplier)	Creates a transport-based fixed rate source.