Package org.talend.sdk.component.junit

Interface ComponentsHandler

All Known Implementing Classes:

BaseComponentsHandler, ComponentExtension, SimpleComponentRule

public interface ComponentsHandler

Test helper allowing you to manipulate mappers/processors unitarly.

Method Summary

Modifier and Type	Method	Description
ComponentManager	asManager()
<T> List<T>	collect(Class<T> recordType, String family, String component, int version, Map<String,String> configuration)
<T> Stream<T>	collect(Class<T> recordType, org.talend.sdk.component.runtime.input.Mapper mapper, int maxRecords)
<T> Stream<T>	collect(Class<T> recordType, org.talend.sdk.component.runtime.input.Mapper mapper, int maxRecords, int concurrency)
BaseComponentsHandler.Outputs	collect(org.talend.sdk.component.runtime.output.Processor processor, ControllableInputFactory inputs)
BaseComponentsHandler.Outputs	collect(org.talend.sdk.component.runtime.output.Processor processor, ControllableInputFactory inputs, int bundleSize)
<T> List<T>	collectAsList(Class<T> recordType, org.talend.sdk.component.runtime.input.Mapper mapper)
<T> List<T>	collectAsList(Class<T> recordType, org.talend.sdk.component.runtime.input.Mapper mapper, int maxRecords)
org.talend.sdk.component.runtime.input.Mapper	createMapper(Class<?> componentType, Object configuration)
org.talend.sdk.component.runtime.output.Processor	createProcessor(Class<?> componentType, Object configuration)
<T> T	findService(Class<T> serviceClass)
<T> T	findService(String plugin, Class<T> serviceClass)
<T> List<T>	getCollectedData(Class<T> recordType)
<T> T	injectServices(T instance)
<T> void	process(Iterable<T> inputs, String family, String component, int version, Map<String,String> configuration)
<T> void	setInputData(Iterable<T> data)

Method Details

collect

BaseComponentsHandler.Outputs collect(org.talend.sdk.component.runtime.output.Processor processor,
 ControllableInputFactory inputs)

collect

BaseComponentsHandler.Outputs collect(org.talend.sdk.component.runtime.output.Processor processor,
 ControllableInputFactory inputs,
 int bundleSize)

collect

<T> Stream<T> collect(Class<T> recordType,
 org.talend.sdk.component.runtime.input.Mapper mapper,
 int maxRecords)

collect

<T> Stream<T> collect(Class<T> recordType,
 org.talend.sdk.component.runtime.input.Mapper mapper,
 int maxRecords,
 int concurrency)

collectAsList

<T> List<T> collectAsList(Class<T> recordType,
 org.talend.sdk.component.runtime.input.Mapper mapper)

collectAsList

<T> List<T> collectAsList(Class<T> recordType,
 org.talend.sdk.component.runtime.input.Mapper mapper,
 int maxRecords)

createMapper

org.talend.sdk.component.runtime.input.Mapper createMapper(Class<?> componentType,
 Object configuration)

createProcessor

org.talend.sdk.component.runtime.output.Processor createProcessor(Class<?> componentType,
 Object configuration)

collect

<T> List<T> collect(Class<T> recordType,
 String family,
 String component,
 int version,
 Map<String,String> configuration)

process

<T> void process(Iterable<T> inputs,
 String family,
 String component,
 int version,
 Map<String,String> configuration)

asManager

ComponentManager asManager()

setInputData

<T> void setInputData(Iterable<T> data)

getCollectedData

<T> List<T> getCollectedData(Class<T> recordType)

findService

<T> T findService(String plugin,
 Class<T> serviceClass)

findService

<T> T findService(Class<T> serviceClass)

injectServices

<T> T injectServices(T instance)