public class TaskInformation extends Object implements Serializable
ExecutionJobVertex
. This information is shared by all sub tasks of this operator.Constructor and Description |
---|
TaskInformation(JobVertexID jobVertexId,
String taskName,
int parallelism,
String invokableClassName,
Configuration taskConfiguration) |
Modifier and Type | Method and Description |
---|---|
String |
getInvokableClassName() |
JobVertexID |
getJobVertexId() |
int |
getParallelism() |
Configuration |
getTaskConfiguration() |
String |
getTaskName() |
public TaskInformation(JobVertexID jobVertexId, String taskName, int parallelism, String invokableClassName, Configuration taskConfiguration)
public JobVertexID getJobVertexId()
public String getTaskName()
public int getParallelism()
public String getInvokableClassName()
public Configuration getTaskConfiguration()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.