Uses of Class
org.apache.tez.runtime.api.InputSpecUpdate

Packages that use InputSpecUpdate

Package	Description
org.apache.tez.dag.api
org.apache.tez.runtime.api
org.apache.tez.runtime.api.events

Uses of InputSpecUpdate in org.apache.tez.dag.api

Method parameters in org.apache.tez.dag.api with type arguments of type InputSpecUpdate

Modifier and Type

Method and Description

void

VertexManagerPluginContext.setVertexParallelism(int parallelism, VertexLocationHint locationHint, Map<String,EdgeManagerPluginDescriptor> sourceEdgeManagers, Map<String,InputSpecUpdate> rootInputSpecUpdate) Set the new parallelism (number of tasks) of this vertex, Map of source (input) vertices and edge managers to change the event routing between the source tasks and the new destination tasks and the number of physical inputs for root inputs.

Uses of InputSpecUpdate in org.apache.tez.runtime.api

Methods in org.apache.tez.runtime.api that return InputSpecUpdate

Modifier and Type	Method and Description
static InputSpecUpdate	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	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.
static InputSpecUpdate	InputSpecUpdate.getDefaultSinglePhysicalInputSpecUpdate()

Uses of InputSpecUpdate in org.apache.tez.runtime.api.events

Methods in org.apache.tez.runtime.api.events that return InputSpecUpdate

Modifier and Type	Method and Description
InputSpecUpdate	InputConfigureVertexTasksEvent.getInputSpecUpdate()

Methods in org.apache.tez.runtime.api.events with parameters of type InputSpecUpdate

Modifier and Type	Method and Description
static InputConfigureVertexTasksEvent	InputConfigureVertexTasksEvent.create(int numTasks, VertexLocationHint locationHint, InputSpecUpdate inputSpecUpdate)