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 and Description
ComponentManager	asManager()
<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)
<T> List<T>	collect(Class<T> recordType, String family, String component, int version, Map<String,String> configuration)
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 Detail

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)