| Package | Description |
|---|---|
| org.apache.flink.runtime.deployment |
| Modifier and Type | Method and Description |
|---|---|
static ResultPartitionDeploymentDescriptor |
ResultPartitionDeploymentDescriptor.from(IntermediateResultPartition partition) |
| Modifier and Type | Method and Description |
|---|---|
List<ResultPartitionDeploymentDescriptor> |
TaskDeploymentDescriptor.getProducedPartitions() |
| Constructor and Description |
|---|
TaskDeploymentDescriptor(JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionId,
String taskName,
int indexInSubtaskGroup,
int numberOfSubtasks,
Configuration jobConfiguration,
Configuration taskConfiguration,
String invokableClassName,
List<ResultPartitionDeploymentDescriptor> producedPartitions,
List<InputGateDeploymentDescriptor> inputGates,
List<BlobKey> requiredJarFiles,
int targetSlotNumber)
Constructs a task deployment descriptor.
|
TaskDeploymentDescriptor(JobID jobID,
JobVertexID vertexID,
ExecutionAttemptID executionId,
String taskName,
int indexInSubtaskGroup,
int numberOfSubtasks,
Configuration jobConfiguration,
Configuration taskConfiguration,
String invokableClassName,
List<ResultPartitionDeploymentDescriptor> producedPartitions,
List<InputGateDeploymentDescriptor> inputGates,
List<BlobKey> requiredJarFiles,
int targetSlotNumber,
StateHandle operatorStates) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.