JobVertex (flink 1.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.runtime.jobgraph.JobVertex

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

InputFormatVertex, OutputFormatVertex
```
public class JobVertex
extends Object
implements Serializable
```
The base class for job vertexes.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor and Description
`JobVertex(String name)` Constructs a new job vertex and assigns it with the given name.
`JobVertex(String name, JobVertexID id)` Constructs a new job vertex and assigns it with the given name.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`JobEdge`	`connectDataSetAsInput(IntermediateDataSet dataSet, DistributionPattern distPattern)`
`void`	`connectIdInput(IntermediateDataSetID dataSetId, DistributionPattern distPattern)`
`JobEdge`	`connectNewDataSetAsInput(JobVertex input, DistributionPattern distPattern)`
`JobEdge`	`connectNewDataSetAsInput(JobVertex input, DistributionPattern distPattern, ResultPartitionType partitionType)`
`JobEdge`	`connectNewDataSetAsInput(JobVertex input, DistributionPattern distPattern, ResultPartitionType partitionType, boolean eagerlyDeployConsumers)`
`IntermediateDataSet`	`createAndAddResultDataSet(IntermediateDataSetID id, ResultPartitionType partitionType)`
`IntermediateDataSet`	`createAndAddResultDataSet(ResultPartitionType partitionType)`
`void`	`finalizeOnMaster(ClassLoader loader)` A hook that can be overwritten by sub classes to implement logic that is called by the master after the job completed.
`CoLocationGroup`	`getCoLocationGroup()`
`Configuration`	`getConfiguration()` Returns the vertex's configuration object which can be used to pass custom settings to the task at runtime.
`JobVertexID`	`getID()` Returns the ID of this job vertex.
`List<JobEdge>`	`getInputs()`
`InputSplitSource<?>`	`getInputSplitSource()`
`Class<? extends AbstractInvokable>`	`getInvokableClass(ClassLoader cl)` Returns the invokable class which represents the task of this vertex
`String`	`getInvokableClassName()` Returns the name of the invokable class which represents the task of this vertex.
`String`	`getName()` Returns the name of the vertex.
`int`	`getNumberOfInputs()` Returns the number of inputs.
`int`	`getNumberOfProducedIntermediateDataSets()` Returns the number of produced intermediate data sets.
`String`	`getOperatorDescription()`
`String`	`getOperatorName()`
`String`	`getOperatorPrettyName()`
`int`	`getParallelism()` Gets the parallelism of the task.
`List<IntermediateDataSet>`	`getProducedDataSets()`
`String`	`getResultOptimizerProperties()`
`SlotSharingGroup`	`getSlotSharingGroup()` Gets the slot sharing group that this vertex is associated with.
`boolean`	`hasNoConnectedInputs()`
`void`	`initializeOnMaster(ClassLoader loader)` A hook that can be overwritten by sub classes to implement logic that is called by the master when the job starts.
`boolean`	`isInputVertex()`
`boolean`	`isOutputVertex()`
`boolean`	`isStoppable()`
`void`	`setInputSplitSource(InputSplitSource<?> inputSplitSource)`
`void`	`setInvokableClass(Class<? extends AbstractInvokable> invokable)`
`void`	`setName(String name)` Sets the name of the vertex
`void`	`setOperatorDescription(String operatorDescription)`
`void`	`setOperatorName(String operatorName)`
`void`	`setOperatorPrettyName(String operatorPrettyName)`
`void`	`setParallelism(int parallelism)` Sets the parallelism for the task.
`void`	`setResultOptimizerProperties(String resultOptimizerProperties)`
`void`	`setSlotSharingGroup(SlotSharingGroup grp)` Associates this vertex with a slot sharing group for scheduling.
`void`	`setStrictlyCoLocatedWith(JobVertex strictlyCoLocatedWith)` Tells this vertex to strictly co locate its subtasks with the subtasks of the given vertex.
`String`	`toString()`
`void`	`updateCoLocationGroup(CoLocationGroup group)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - JobVertex
```
public JobVertex(String name)
```
    Constructs a new job vertex and assigns it with the given name.
    
    Parameters:
    
    name - The name of the new job vertex.
  - JobVertex
```
public JobVertex(String name,
                 JobVertexID id)
```
    Constructs a new job vertex and assigns it with the given name.
    
    Parameters:
    
    name - The name of the new job vertex.
    
    id - The id of the job vertex.
- Method Detail
  - getID
```
public JobVertexID getID()
```
    Returns the ID of this job vertex.
    
    Returns:
    
    The ID of this job vertex
  - getName
```
public String getName()
```
    Returns the name of the vertex.
    
    Returns:
    
    The name of the vertex.
  - setName
```
public void setName(String name)
```
    Sets the name of the vertex
    
    Parameters:
    
    name - The new name.
  - getNumberOfProducedIntermediateDataSets
```
public int getNumberOfProducedIntermediateDataSets()
```
    Returns the number of produced intermediate data sets.
    
    Returns:
    
    The number of produced intermediate data sets.
  - getNumberOfInputs
```
public int getNumberOfInputs()
```
    Returns the number of inputs.
    
    Returns:
    
    The number of inputs.
  - getConfiguration
```
public Configuration getConfiguration()
```
    Returns the vertex's configuration object which can be used to pass custom settings to the task at runtime.
    
    Returns:
    
    the vertex's configuration object
  - setInvokableClass
```
public void setInvokableClass(Class<? extends AbstractInvokable> invokable)
```
  - getInvokableClassName
```
public String getInvokableClassName()
```
    Returns the name of the invokable class which represents the task of this vertex.
    
    Returns:
    
    The name of the invokable class, null if not set.
  - getInvokableClass
```
public Class<? extends AbstractInvokable> getInvokableClass(ClassLoader cl)
```
    Returns the invokable class which represents the task of this vertex
    
    Parameters:
    
    cl - The classloader used to resolve user-defined classes
    
    Returns:
    
    The invokable class, null if it is not set
  - getParallelism
```
public int getParallelism()
```
    Gets the parallelism of the task.
    
    Returns:
    
    The parallelism of the task.
  - setParallelism
```
public void setParallelism(int parallelism)
```
    Sets the parallelism for the task.
    
    Parameters:
    
    parallelism - The parallelism for the task.
  - getInputSplitSource
```
public InputSplitSource<?> getInputSplitSource()
```
  - setInputSplitSource
```
public void setInputSplitSource(InputSplitSource<?> inputSplitSource)
```
  - getProducedDataSets
```
public List<IntermediateDataSet> getProducedDataSets()
```
  - getInputs
```
public List<JobEdge> getInputs()
```
  - setSlotSharingGroup
```
public void setSlotSharingGroup(SlotSharingGroup grp)
```
    Associates this vertex with a slot sharing group for scheduling. Different vertices in the same slot sharing group can run one subtask each in the same slot.
    
    Parameters:
    
    grp - The slot sharing group to associate the vertex with.
  - getSlotSharingGroup
```
public SlotSharingGroup getSlotSharingGroup()
```
    Gets the slot sharing group that this vertex is associated with. Different vertices in the same slot sharing group can run one subtask each in the same slot. If the vertex is not associated with a slot sharing group, this method returns null.
    
    Returns:
    
    The slot sharing group to associate the vertex with, or null, if not associated with one.
  - setStrictlyCoLocatedWith
```
public void setStrictlyCoLocatedWith(JobVertex strictlyCoLocatedWith)
```
    Tells this vertex to strictly co locate its subtasks with the subtasks of the given vertex. Strict co-location implies that the n'th subtask of this vertex will run on the same parallel computing instance (TaskManager) as the n'th subtask of the given vertex. NOTE: Co-location is only possible between vertices in a slot sharing group. NOTE: This vertex must (transitively) depend on the vertex to be co-located with. That means that the respective vertex must be a (transitive) input of this vertex.
    
    Parameters:
    
    strictlyCoLocatedWith - The vertex whose subtasks to co-locate this vertex's subtasks with.
    
    Throws:
    
    IllegalArgumentException - Thrown, if this vertex and the vertex to co-locate with are not in a common slot sharing group.
    
    See Also:
    
    setSlotSharingGroup(SlotSharingGroup)
  - getCoLocationGroup
```
public CoLocationGroup getCoLocationGroup()
```
  - updateCoLocationGroup
```
public void updateCoLocationGroup(CoLocationGroup group)
```
  - createAndAddResultDataSet
```
public IntermediateDataSet createAndAddResultDataSet(ResultPartitionType partitionType)
```
  - createAndAddResultDataSet
```
public IntermediateDataSet createAndAddResultDataSet(IntermediateDataSetID id,
                                                     ResultPartitionType partitionType)
```
  - connectDataSetAsInput
```
public JobEdge connectDataSetAsInput(IntermediateDataSet dataSet,
                                     DistributionPattern distPattern)
```
  - connectNewDataSetAsInput
```
public JobEdge connectNewDataSetAsInput(JobVertex input,
                                        DistributionPattern distPattern)
```
  - connectNewDataSetAsInput
```
public JobEdge connectNewDataSetAsInput(JobVertex input,
                                        DistributionPattern distPattern,
                                        ResultPartitionType partitionType)
```
  - connectNewDataSetAsInput
```
public JobEdge connectNewDataSetAsInput(JobVertex input,
                                        DistributionPattern distPattern,
                                        ResultPartitionType partitionType,
                                        boolean eagerlyDeployConsumers)
```
  - connectIdInput
```
public void connectIdInput(IntermediateDataSetID dataSetId,
                           DistributionPattern distPattern)
```
  - isInputVertex
```
public boolean isInputVertex()
```
  - isStoppable
```
public boolean isStoppable()
```
  - isOutputVertex
```
public boolean isOutputVertex()
```
  - hasNoConnectedInputs
```
public boolean hasNoConnectedInputs()
```
  - initializeOnMaster
```
public void initializeOnMaster(ClassLoader loader)
                        throws Exception
```
    A hook that can be overwritten by sub classes to implement logic that is called by the master when the job starts.
    
    Parameters:
    
    loader - The class loader for user defined code.
    
    Throws:
    
    Exception - The method may throw exceptions which cause the job to fail immediately.
  - finalizeOnMaster
```
public void finalizeOnMaster(ClassLoader loader)
                      throws Exception
```
    A hook that can be overwritten by sub classes to implement logic that is called by the master after the job completed.
    
    Parameters:
    
    loader - The class loader for user defined code.
    
    Throws:
    
    Exception - The method may throw exceptions which cause the job to fail immediately.
  - getOperatorName
```
public String getOperatorName()
```
  - setOperatorName
```
public void setOperatorName(String operatorName)
```
  - getOperatorDescription
```
public String getOperatorDescription()
```
  - setOperatorDescription
```
public void setOperatorDescription(String operatorDescription)
```
  - setOperatorPrettyName
```
public void setOperatorPrettyName(String operatorPrettyName)
```
  - getOperatorPrettyName
```
public String getOperatorPrettyName()
```
  - getResultOptimizerProperties
```
public String getResultOptimizerProperties()
```
  - setResultOptimizerProperties
```
public void setResultOptimizerProperties(String resultOptimizerProperties)
```
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Back to Flink Website

Class JobVertex

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

JobVertex

JobVertex

Method Detail

getID

getName

setName

getNumberOfProducedIntermediateDataSets

getNumberOfInputs

getConfiguration

setInvokableClass

getInvokableClassName

getInvokableClass

getParallelism

setParallelism

getInputSplitSource

setInputSplitSource

getProducedDataSets

getInputs

setSlotSharingGroup

getSlotSharingGroup

setStrictlyCoLocatedWith

getCoLocationGroup

updateCoLocationGroup

createAndAddResultDataSet

createAndAddResultDataSet

connectDataSetAsInput

connectNewDataSetAsInput

connectNewDataSetAsInput

connectNewDataSetAsInput

connectIdInput

isInputVertex

isStoppable

isOutputVertex

hasNoConnectedInputs

initializeOnMaster

finalizeOnMaster

getOperatorName

setOperatorName

getOperatorDescription

setOperatorDescription

setOperatorPrettyName

getOperatorPrettyName

getResultOptimizerProperties

setResultOptimizerProperties

toString

Back to Flink Website