Package org.talend.sdk.component.junit

Class JoinInputFactory

java.lang.Object

org.talend.sdk.component.junit.JoinInputFactory

All Implemented Interfaces:

ControllableInputFactory, org.talend.sdk.component.runtime.output.InputFactory

public class JoinInputFactory
extends Object
implements ControllableInputFactory

An input factory which joins multiple distinct sources reading them in "parallel". IMPORTANT: all entries of the map but have the same "size".

Constructor Summary

Constructors

Constructor	Description
JoinInputFactory()

Method Summary

Modifier and Type	Method	Description
org.talend.sdk.component.junit.InputFactoryIterable	asInputRecords()
boolean	hasMoreData()
Object	read(String name)
JoinInputFactory	withInput(String branch, Collection<?> branchData)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JoinInputFactory

public JoinInputFactory()

Method Details

withInput

public JoinInputFactory withInput(String branch,
 Collection<?> branchData)

read

public Object read(String name)

Specified by:

read in interface org.talend.sdk.component.runtime.output.InputFactory

hasMoreData

public boolean hasMoreData()

Specified by:

hasMoreData in interface ControllableInputFactory

asInputRecords

public org.talend.sdk.component.junit.InputFactoryIterable asInputRecords()

Specified by:

asInputRecords in interface ControllableInputFactory