org.apache.tez.runtime.library.input

Class OrderedGroupedMergedKVInput

java.lang.Object

org.apache.tez.runtime.api.MergedLogicalInput

org.apache.tez.runtime.library.input.OrderedGroupedMergedKVInput

All Implemented Interfaces:

org.apache.tez.runtime.api.Input, org.apache.tez.runtime.api.LogicalInput

@InterfaceAudience.Public
public class OrderedGroupedMergedKVInput
extends org.apache.tez.runtime.api.MergedLogicalInput

A MergedLogicalInput which merges multiple OrderedGroupedKVInputs and returns a single view of these by merging values which belong to the same key. Combiners and Secondary Sort are not implemented, so there is no guarantee on the order of values.

Constructor Summary

Constructors

Constructor and Description
OrderedGroupedMergedKVInput(org.apache.tez.runtime.api.MergedInputContext context, List<org.apache.tez.runtime.api.Input> inputs)

Method Summary

Modifier and Type	Method and Description
float	getProgress()
KeyValuesReader	getReader() Provides an ordered KeyValuesReader
void	setConstituentInputIsReady(org.apache.tez.runtime.api.Input input)

Methods inherited from class org.apache.tez.runtime.api.MergedLogicalInput

getContext, getInputs, informInputReady, start

Methods inherited from class java.lang.Object

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

Constructor Detail

OrderedGroupedMergedKVInput

public OrderedGroupedMergedKVInput(org.apache.tez.runtime.api.MergedInputContext context,
                                   List<org.apache.tez.runtime.api.Input> inputs)

Method Detail

getReader

public KeyValuesReader getReader()
                          throws Exception

Provides an ordered KeyValuesReader

Throws:

Exception

setConstituentInputIsReady

public void setConstituentInputIsReady(org.apache.tez.runtime.api.Input input)

Specified by:

setConstituentInputIsReady in class org.apache.tez.runtime.api.MergedLogicalInput

getProgress

public float getProgress()
                  throws org.apache.tez.runtime.api.ProgressFailedException,
                         InterruptedException

Overrides:

getProgress in class org.apache.tez.runtime.api.MergedLogicalInput

Throws:

org.apache.tez.runtime.api.ProgressFailedException

InterruptedException