org.apache.tez.runtime.library.input

Class ConcatenatedMergedKeyValuesInput

java.lang.Object

org.apache.tez.runtime.api.MergedLogicalInput

org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValuesInput

All Implemented Interfaces:

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

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

Implements a MergedLogicalInput that merges the incoming inputs (e.g. from a GroupInputEdge and provide a unified view of the input. It concatenates all the inputs to provide a unified view

Constructor Summary

Constructors

Constructor and Description
ConcatenatedMergedKeyValuesInput(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 a KeyValuesReader that iterates over the concatenated input data
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

ConcatenatedMergedKeyValuesInput

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

Method Detail

getReader

public KeyValuesReader getReader()
                          throws Exception

Provides a KeyValuesReader that iterates over the concatenated input data

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