org.apache.flink.runtime.deployment

Class InputGateDeploymentDescriptor

java.lang.Object

org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor

All Implemented Interfaces:

Serializable

public class InputGateDeploymentDescriptor
extends Object
implements Serializable

Deployment descriptor for a single input gate instance.

Each input gate consumes partitions of a single intermediate result. The consumed subpartition index range is the same for each consumed partition.

See Also:

SingleInputGate, Serialized Form

Constructor Summary

Constructors

Constructor and Description
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, int consumedSubpartitionIndex, ShuffleDescriptor[] inputChannels)
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, SubpartitionIndexRange consumedSubpartitionIndexRange, TaskDeploymentDescriptor.MaybeOffloaded<ShuffleDescriptor[]> serializedInputChannels)

Method Summary

Modifier and Type	Method and Description
ResultPartitionType	getConsumedPartitionType() Returns the type of this input channel's consumed result partition.
IntermediateDataSetID	getConsumedResultId()
int	getConsumedSubpartitionIndex()
SubpartitionIndexRange	getConsumedSubpartitionIndexRange() Return the index range of the the consumed subpartitions.
ShuffleDescriptor[]	getShuffleDescriptors()
void	loadBigData(PermanentBlobService blobService, JobID jobId)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

InputGateDeploymentDescriptor

@VisibleForTesting
public InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
                                                        ResultPartitionType consumedPartitionType,
                                                        @Nonnegative
                                                        int consumedSubpartitionIndex,
                                                        ShuffleDescriptor[] inputChannels)
                                                 throws IOException

Throws:

IOException

InputGateDeploymentDescriptor

public InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
                                     ResultPartitionType consumedPartitionType,
                                     SubpartitionIndexRange consumedSubpartitionIndexRange,
                                     TaskDeploymentDescriptor.MaybeOffloaded<ShuffleDescriptor[]> serializedInputChannels)

Method Detail

getConsumedResultId

public IntermediateDataSetID getConsumedResultId()

getConsumedPartitionType

public ResultPartitionType getConsumedPartitionType()

Returns the type of this input channel's consumed result partition.

Returns:

consumed result partition type

getConsumedSubpartitionIndex

@Nonnegative
public int getConsumedSubpartitionIndex()

getConsumedSubpartitionIndexRange

public SubpartitionIndexRange getConsumedSubpartitionIndexRange()

Return the index range of the the consumed subpartitions.

loadBigData

public void loadBigData(@Nullable
                        PermanentBlobService blobService,
                        JobID jobId)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

getShuffleDescriptors

public ShuffleDescriptor[] getShuffleDescriptors()

toString

public String toString()

Overrides:

toString in class Object