Uses of Class
org.apache.flink.runtime.io.network.partition.ResultPartitionType

Packages that use ResultPartitionType

Package	Description
org.apache.flink.runtime.deployment
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.topology
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.topology

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

Methods in org.apache.flink.runtime.deployment that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	InputGateDeploymentDescriptor.getConsumedPartitionType() Returns the type of this input channel's consumed result partition.
ResultPartitionType	ResultPartitionDeploymentDescriptor.getPartitionType()

Constructors in org.apache.flink.runtime.deployment with parameters of type ResultPartitionType

Constructor and Description
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, int consumedSubpartitionIndex, ShuffleDescriptor[] inputChannels)

Uses of ResultPartitionType in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	IntermediateResultPartition.getResultType()
ResultPartitionType	IntermediateResult.getResultType()

Constructors in org.apache.flink.runtime.executiongraph with parameters of type ResultPartitionType

Constructor and Description
IntermediateResult(IntermediateDataSetID id, ExecutionJobVertex producer, int numParallelProducers, ResultPartitionType resultType)

Uses of ResultPartitionType in org.apache.flink.runtime.io.network.partition

Fields in org.apache.flink.runtime.io.network.partition declared as ResultPartitionType

Modifier and Type	Field and Description
protected ResultPartitionType	ResultPartition.partitionType Type of this partition.

Methods in org.apache.flink.runtime.io.network.partition that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	ResultPartition.getPartitionType() Returns the type of this result partition.
static ResultPartitionType	ResultPartitionType.valueOf(String name) Returns the enum constant of this type with the specified name.
static ResultPartitionType[]	ResultPartitionType.values() Returns an array containing the constants of this enum type, in the order they are declared.

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

Modifier and Type	Method and Description
ResultPartition	ResultPartitionFactory.create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory)

Constructors in org.apache.flink.runtime.io.network.partition with parameters of type ResultPartitionType

Constructor and Description
ResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory)

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

Methods in org.apache.flink.runtime.io.network.partition.consumer that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	SingleInputGate.getConsumedPartitionType() Returns the type of this input channel's consumed result partition.

Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type ResultPartitionType

Constructor and Description

SingleInputGate(String owningTaskName, int gateIndex, IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, int consumedSubpartitionIndex, int numberOfInputChannels, PartitionProducerStateProvider partitionProducerStateProvider, SupplierWithException<BufferPool,IOException> bufferPoolFactory, BufferDecompressor bufferDecompressor, MemorySegmentProvider memorySegmentProvider)

Uses of ResultPartitionType in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	IntermediateDataSet.getResultType()

Methods in org.apache.flink.runtime.jobgraph with parameters of type ResultPartitionType

Modifier and Type	Method and Description
JobEdge	JobVertex.connectNewDataSetAsInput(JobVertex input, DistributionPattern distPattern, ResultPartitionType partitionType)
IntermediateDataSet	JobVertex.createAndAddResultDataSet(IntermediateDataSetID id, ResultPartitionType partitionType)
IntermediateDataSet	JobVertex.createAndAddResultDataSet(ResultPartitionType partitionType)

Constructors in org.apache.flink.runtime.jobgraph with parameters of type ResultPartitionType

Constructor and Description
IntermediateDataSet(IntermediateDataSetID id, ResultPartitionType resultType, JobVertex producer)

Uses of ResultPartitionType in org.apache.flink.runtime.jobgraph.topology

Methods in org.apache.flink.runtime.jobgraph.topology that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	DefaultLogicalResult.getResultType()

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

Methods in org.apache.flink.runtime.shuffle that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	PartitionDescriptor.getPartitionType()

Constructors in org.apache.flink.runtime.shuffle with parameters of type ResultPartitionType

Constructor and Description
PartitionDescriptor(IntermediateDataSetID resultId, int totalNumberOfPartitions, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, int connectionIndex)

Uses of ResultPartitionType in org.apache.flink.runtime.topology

Methods in org.apache.flink.runtime.topology that return ResultPartitionType

Modifier and Type	Method and Description
ResultPartitionType	Result.getResultType()