| Package | Description | 
|---|---|
| org.apache.tez.dag.api | |
| org.apache.tez.runtime.api | |
| org.apache.tez.runtime.api.events | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
VertexManagerPluginContext.reconfigureVertex(int parallelism,
                 VertexLocationHint locationHint,
                 Map<String,EdgeProperty> sourceEdgeProperties,
                 Map<String,InputSpecUpdate> rootInputSpecUpdate)
API to reconfigure a  
Vertex that is reading root inputs based on
 the data read from the root inputs. | 
void | 
VertexManagerPluginContext.reconfigureVertex(Map<String,InputSpecUpdate> rootInputSpecUpdate,
                 VertexLocationHint locationHint,
                 int parallelism)
API to reconfigure a  
Vertex that is reading root inputs based on
 the data read from the root inputs. | 
void | 
VertexManagerPluginContext.setVertexParallelism(int parallelism,
                    VertexLocationHint locationHint,
                    Map<String,EdgeManagerPluginDescriptor> sourceEdgeManagers,
                    Map<String,InputSpecUpdate> rootInputSpecUpdate)
Deprecated.  
 | 
| 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()  | 
| Modifier and Type | Method and Description | 
|---|---|
InputSpecUpdate | 
InputConfigureVertexTasksEvent.getInputSpecUpdate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static InputConfigureVertexTasksEvent | 
InputConfigureVertexTasksEvent.create(int numTasks,
      VertexLocationHint locationHint,
      InputSpecUpdate inputSpecUpdate)  | 
Copyright © 2021 Apache Software Foundation. All rights reserved.