Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.state |
Modifier and Type | Method and Description |
---|---|
JobManagerTaskRestore |
TaskDeploymentDescriptor.getTaskRestore() |
Modifier and Type | Method and Description |
---|---|
TaskDeploymentDescriptor |
TaskDeploymentDescriptorFactory.createDeploymentDescriptor(AllocationID allocationID,
int targetSlotNumber,
JobManagerTaskRestore taskRestore,
Collection<ResultPartitionDeploymentDescriptor> producedPartitions) |
Constructor and Description |
---|
TaskDeploymentDescriptor(JobID jobId,
TaskDeploymentDescriptor.MaybeOffloaded<JobInformation> serializedJobInformation,
TaskDeploymentDescriptor.MaybeOffloaded<TaskInformation> serializedTaskInformation,
ExecutionAttemptID executionAttemptId,
AllocationID allocationId,
int subtaskIndex,
int attemptNumber,
int targetSlotNumber,
JobManagerTaskRestore taskRestore,
List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors,
List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
Modifier and Type | Method and Description |
---|---|
JobManagerTaskRestore |
Execution.getTaskRestore() |
Modifier and Type | Method and Description |
---|---|
void |
Execution.setInitialState(JobManagerTaskRestore taskRestore)
Sets the initial state for the execution.
|
Constructor and Description |
---|
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder) |
TaskStateManagerImpl(JobID jobId,
ExecutionAttemptID executionAttemptID,
TaskLocalStateStore localStateStore,
JobManagerTaskRestore jobManagerTaskRestore,
CheckpointResponder checkpointResponder,
ChannelStateReader channelStateReader) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.