Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.io.network.partition.consumer |
Modifier and Type | Method and Description |
---|---|
static SubpartitionIndexRange |
TaskDeploymentDescriptorFactory.computeConsumedSubpartitionRange(int numConsumers,
IntermediateResultPartition resultPartition,
int consumerSubtaskIndex) |
SubpartitionIndexRange |
InputGateDeploymentDescriptor.getConsumedSubpartitionIndexRange()
Return the index range of the the consumed subpartitions.
|
Constructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
SubpartitionIndexRange consumedSubpartitionIndexRange,
TaskDeploymentDescriptor.MaybeOffloaded<ShuffleDescriptor[]> serializedInputChannels) |
Constructor and Description |
---|
SingleInputGate(String owningTaskName,
int gateIndex,
IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
SubpartitionIndexRange subpartitionIndexRange,
int numberOfInputChannels,
PartitionProducerStateProvider partitionProducerStateProvider,
SupplierWithException<BufferPool,IOException> bufferPoolFactory,
BufferDecompressor bufferDecompressor,
MemorySegmentProvider memorySegmentProvider,
int segmentSize,
ThroughputCalculator throughputCalculator,
BufferDebloater bufferDebloater) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.