MostFullJoinPolicy

constructor(tags: Iterable<InputTag<Container<*>>> = generateSequence { newDynamicInputTag { it.walkUpstream().filterIsInstance<Container<*>>().first() } } .asIterable())

Parameters

T

the type of entities being merged

tags

the tags used to identify upstream containers for each source