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

public class ConcatenatedMergedKeyValuesInput
extends org.apache.tez.runtime.api.MergedLogicalInput

Nested Class Summary

class

ConcatenatedMergedKeyValuesInput.ConcatenatedMergedKeyValuesReader

Constructor Summary

ConcatenatedMergedKeyValuesInput()

Method Summary

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

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

close, getInputs, handleEvents, informInputReady, initialize, initialize, setInputReadyCallback, setNumPhysicalInputs, start

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcatenatedMergedKeyValuesInput

public ConcatenatedMergedKeyValuesInput()

Method Detail

getReader

public org.apache.tez.runtime.api.Reader getReader()
                                            throws Exception

Throws:

Exception

setConstituentInputIsReady

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

Specified by:

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