org.apache.tez.runtime.library.input
Class LocalMergedInput

java.lang.Object
  org.apache.tez.runtime.library.input.ShuffledMergedInput
      org.apache.tez.runtime.library.input.ShuffledMergedInputLegacy
          org.apache.tez.runtime.library.input.LocalMergedInput

All Implemented Interfaces:

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

public class LocalMergedInput
extends ShuffledMergedInputLegacy

LocalMergedInput in an LogicalInput which shuffles intermediate sorted data, merges them and provides key/ to the consumer.

Field Summary

Fields inherited from class org.apache.tez.runtime.library.input.ShuffledMergedInput

conf, inputContext, memoryUpdateCallbackHandler, numInputs, rawIter, shuffle, vIter

Constructor Summary

LocalMergedInput()

Method Summary

List<org.apache.tez.runtime.api.Event>	close()
List<org.apache.tez.runtime.api.Event>	initialize(org.apache.tez.runtime.api.TezInputContext inputContext)
void	start()

Methods inherited from class org.apache.tez.runtime.library.input.ShuffledMergedInputLegacy

getIterator

Methods inherited from class org.apache.tez.runtime.library.input.ShuffledMergedInput

createValuesIterator, getReader, handleEvents, isInputReady, setNumPhysicalInputs, waitForInputReady

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalMergedInput

public LocalMergedInput()

Method Detail

initialize

public List<org.apache.tez.runtime.api.Event> initialize(org.apache.tez.runtime.api.TezInputContext inputContext)
                                                  throws IOException

Specified by:

initialize in interface org.apache.tez.runtime.api.Input

Overrides:

initialize in class ShuffledMergedInput

Throws:

IOException

start

public void start()
           throws IOException

Specified by:

start in interface org.apache.tez.runtime.api.Input

Overrides:

start in class ShuffledMergedInput

Throws:

IOException

close

public List<org.apache.tez.runtime.api.Event> close()
                                             throws IOException

Specified by:

close in interface org.apache.tez.runtime.api.Input

Overrides:

close in class ShuffledMergedInput

Throws:

IOException