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 numberOfSubtasks,
int numberOfKeyGroups,
String invokableClassName,
Configuration taskConfiguration) |
Modifier and Type | Method and Description |
---|---|
String |
getInvokableClassName() |
JobVertexID |
getJobVertexId() |
int |
getNumberOfKeyGroups() |
int |
getNumberOfSubtasks() |
Configuration |
getTaskConfiguration() |
String |
getTaskName() |
public TaskInformation(JobVertexID jobVertexId, String taskName, int numberOfSubtasks, int numberOfKeyGroups, String invokableClassName, Configuration taskConfiguration)
public JobVertexID getJobVertexId()
public String getTaskName()
public int getNumberOfSubtasks()
public int getNumberOfKeyGroups()
public String getInvokableClassName()
public Configuration getTaskConfiguration()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.