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

java.lang.Object
  org.apache.tez.runtime.library.input.ShuffledUnorderedKVInput

All Implemented Interfaces:

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

public class ShuffledUnorderedKVInput
extends Object
implements org.apache.tez.runtime.api.LogicalInput

Constructor Summary

ShuffledUnorderedKVInput()

Method Summary

List<org.apache.tez.runtime.api.Event>	close()
KeyValueReader	getReader()
void	handleEvents(List<org.apache.tez.runtime.api.Event> inputEvents)
List<org.apache.tez.runtime.api.Event>	initialize(org.apache.tez.runtime.api.TezInputContext inputContext)
void	setNumPhysicalInputs(int numInputs)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ShuffledUnorderedKVInput

public ShuffledUnorderedKVInput()

Method Detail

initialize

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

Specified by:

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

Throws:

Exception

start

public void start()
           throws IOException

Specified by:

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

Throws:

IOException

getReader

public KeyValueReader getReader()
                         throws Exception

Specified by:

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

Throws:

Exception

handleEvents

public void handleEvents(List<org.apache.tez.runtime.api.Event> inputEvents)
                  throws IOException

Specified by:

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

Throws:

IOException

close

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

Specified by:

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

Throws:

Exception

setNumPhysicalInputs

public void setNumPhysicalInputs(int numInputs)

Specified by:

setNumPhysicalInputs in interface org.apache.tez.runtime.api.LogicalInput