Uses of Class
org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor

Packages that use InputGateDeploymentDescriptor

Package	Description
org.apache.flink.runtime.deployment
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.taskmanager

Uses of InputGateDeploymentDescriptor in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return types with arguments of type InputGateDeploymentDescriptor

Modifier and Type	Method and Description
List<InputGateDeploymentDescriptor>	TaskDeploymentDescriptor.getInputGates()

Constructor parameters in org.apache.flink.runtime.deployment with type arguments of type InputGateDeploymentDescriptor

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)

Uses of InputGateDeploymentDescriptor in org.apache.flink.runtime.io.network

Method parameters in org.apache.flink.runtime.io.network with type arguments of type InputGateDeploymentDescriptor

Modifier and Type	Method and Description
List<SingleInputGate>	NettyShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext, PartitionProducerStateProvider partitionProducerStateProvider, List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors)

Uses of InputGateDeploymentDescriptor in org.apache.flink.runtime.io.network.partition.consumer

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type InputGateDeploymentDescriptor

Modifier and Type	Method and Description
SingleInputGate	SingleInputGateFactory.create(String owningTaskName, int gateIndex, InputGateDeploymentDescriptor igdd, PartitionProducerStateProvider partitionProducerStateProvider, InputChannelMetrics metrics) Creates an input gate and all of its input channels.

Uses of InputGateDeploymentDescriptor in org.apache.flink.runtime.shuffle

Method parameters in org.apache.flink.runtime.shuffle with type arguments of type InputGateDeploymentDescriptor

Modifier and Type	Method and Description
List<G>	ShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext, PartitionProducerStateProvider partitionProducerStateProvider, List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) Factory method for the InputGates to consume result partitions.

Uses of InputGateDeploymentDescriptor in org.apache.flink.runtime.taskmanager

Constructor parameters in org.apache.flink.runtime.taskmanager with type arguments of type InputGateDeploymentDescriptor

Constructor and Description

Task(JobInformation jobInformation, TaskInformation taskInformation, ExecutionAttemptID executionAttemptID, AllocationID slotAllocationId, int subtaskIndex, int attemptNumber, List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors, List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors, int targetSlotNumber, MemoryManager memManager, IOManager ioManager, ShuffleEnvironment<?,?> shuffleEnvironment, KvStateService kvStateService, BroadcastVariableManager bcVarManager, TaskEventDispatcher taskEventDispatcher, ExternalResourceInfoProvider externalResourceInfoProvider, TaskStateManager taskStateManager, TaskManagerActions taskManagerActions, InputSplitProvider inputSplitProvider, CheckpointResponder checkpointResponder, TaskOperatorEventGateway operatorCoordinatorEventGateway, GlobalAggregateManager aggregateManager, LibraryCacheManager.ClassLoaderHandle classLoaderHandle, FileCache fileCache, TaskManagerRuntimeInfo taskManagerConfig, TaskMetricGroup metricGroup, ResultPartitionConsumableNotifier resultPartitionConsumableNotifier, PartitionProducerStateChecker partitionProducerStateChecker, Executor executor) IMPORTANT: This constructor may not start any work that would need to be undone in the case of a failing task deployment.