org.apache.tez.runtime.library.input

Class ConcatenatedMergedKeyValueInput

java.lang.Object

org.apache.tez.runtime.api.MergedLogicalInput

org.apache.tez.runtime.library.input.ConcatenatedMergedKeyValueInput

All Implemented Interfaces:

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

@InterfaceAudience.Public
public class ConcatenatedMergedKeyValueInput
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
ConcatenatedMergedKeyValueInput(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()
KeyValueReader	getReader() Provides a KeyValueReader 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

ConcatenatedMergedKeyValueInput

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

Method Detail

getReader

public KeyValueReader getReader()
                         throws Exception

Provides a KeyValueReader 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