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

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

Nested Class Summary

class

ConcatenatedMergedKeyValueInput.ConcatenatedMergedKeyValueReader

Constructor Summary

ConcatenatedMergedKeyValueInput()

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

ConcatenatedMergedKeyValueInput

public ConcatenatedMergedKeyValueInput()

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