org.apache.tez.runtime.api

Class InputSpecUpdate

java.lang.Object

org.apache.tez.runtime.api.InputSpecUpdate

@InterfaceStability.Unstable
@InterfaceAudience.Public
public class InputSpecUpdate
extends Object

Update Input specs for Inputs running in a task. Allows setting the number of physical inputs for all work units if they have the same number of physical inputs, or individual numPhysicalInputs for each work unit.

Method Summary

Methods

Modifier and Type	Method and Description
static InputSpecUpdate	createAllTaskInputSpecUpdate(int numPhysicalInputs) Create an update instance where all work units (typically represented by InputDataInformationEvent) will have the same number of physical inputs.
static InputSpecUpdate	createPerTaskInputSpecUpdate(List<Integer> perWorkUnitNumPhysicalInputs) Create an update instance where all work units (typically represented by InputDataInformationEvent) will have the same number of physical inputs.
List<Integer>	getAllNumPhysicalInputs()
static InputSpecUpdate	getDefaultSinglePhysicalInputSpecUpdate()
int	getNumPhysicalInputsForWorkUnit(int index)
boolean	isForAllWorkUnits()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

createAllTaskInputSpecUpdate

public static InputSpecUpdate createAllTaskInputSpecUpdate(int numPhysicalInputs)

Create an update instance where all work units (typically represented by InputDataInformationEvent) will have the same number of physical inputs.

Parameters:

numPhysicalInputs - the number of physical inputs for all work units which will use the LogicalInput

Returns:

a new InputSpecUpdate instance given the parameters

createPerTaskInputSpecUpdate

public static InputSpecUpdate createPerTaskInputSpecUpdate(List<Integer> perWorkUnitNumPhysicalInputs)

Create an update instance where all work units (typically represented by InputDataInformationEvent) will have the same number of physical inputs.

Parameters:

perWorkUnitNumPhysicalInputs - A list containing one entry per work unit. The order in the list corresponds to task index or equivalently the order of InputDataInformationEvents being sent.

Returns:

a new InputSpecUpdate instance given the parameters

getDefaultSinglePhysicalInputSpecUpdate

public static InputSpecUpdate getDefaultSinglePhysicalInputSpecUpdate()

getNumPhysicalInputsForWorkUnit

@InterfaceAudience.Private
public int getNumPhysicalInputsForWorkUnit(int index)

isForAllWorkUnits

@InterfaceAudience.Private
public boolean isForAllWorkUnits()

getAllNumPhysicalInputs

@InterfaceAudience.Private
public List<Integer> getAllNumPhysicalInputs()

toString

public String toString()

Overrides:

toString in class Object