org.apache.tez.runtime.library.input

Class UnorderedKVInput

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalInput

org.apache.tez.runtime.library.input.UnorderedKVInput

All Implemented Interfaces:

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

@InterfaceAudience.Public
public class UnorderedKVInput
extends org.apache.tez.runtime.api.AbstractLogicalInput

UnorderedKVInput provides unordered key value input by bringing together (shuffling) a set of distributed data and providing a unified view to that data. There are no ordering constraints applied by this input.

Constructor Summary

Constructors

Constructor and Description
UnorderedKVInput(org.apache.tez.runtime.api.InputContext inputContext, int numPhysicalInputs)

Method Summary

Modifier and Type	Method and Description
List<org.apache.tez.runtime.api.Event>	close()
float	getProgress()
KeyValueReader	getReader()
void	handleEvents(List<org.apache.tez.runtime.api.Event> inputEvents)
List<org.apache.tez.runtime.api.Event>	initialize()
void	start()

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

getContext, getNumPhysicalInputs

Methods inherited from class java.lang.Object

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

Constructor Detail

UnorderedKVInput

public UnorderedKVInput(org.apache.tez.runtime.api.InputContext inputContext,
                        int numPhysicalInputs)

Method Detail

initialize

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

Specified by:

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

Specified by:

initialize in class org.apache.tez.runtime.api.AbstractLogicalInput

Throws:

Exception

start

public void start()
           throws IOException

Throws:

IOException

getReader

public KeyValueReader getReader()
                         throws Exception

Throws:

Exception

handleEvents

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

Throws:

IOException

close

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

Throws:

Exception

getProgress

public float getProgress()
                  throws org.apache.tez.runtime.api.ProgressFailedException,
                         InterruptedException

Overrides:

getProgress in class org.apache.tez.runtime.api.AbstractLogicalInput

Throws:

org.apache.tez.runtime.api.ProgressFailedException

InterruptedException