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(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 © 2016 Apache Software Foundation. All rights reserved.