Uses of Class
org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty.TieredStorageNettyServiceImpl
-
Packages that use TieredStorageNettyServiceImpl Package Description org.apache.flink.runtime.io.network.partition.consumer org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle -
-
Uses of TieredStorageNettyServiceImpl in org.apache.flink.runtime.io.network.partition.consumer
Constructors in org.apache.flink.runtime.io.network.partition.consumer with parameters of type TieredStorageNettyServiceImpl Constructor Description SingleInputGate(String owningTaskName, int gateIndex, IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange subpartitionIndexRange, int numberOfInputChannels, PartitionProducerStateProvider partitionProducerStateProvider, org.apache.flink.util.function.SupplierWithException<BufferPool,IOException> bufferPoolFactory, BufferDecompressor bufferDecompressor, org.apache.flink.core.memory.MemorySegmentProvider memorySegmentProvider, int segmentSize, ThroughputCalculator throughputCalculator, BufferDebloater bufferDebloater, TieredStorageConsumerClient tieredStorageConsumerClient, TieredStorageNettyServiceImpl nettyService, List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs)SingleInputGateFactory(ResourceID taskExecutorResourceId, NettyShuffleEnvironmentConfiguration networkConfig, ConnectionManager connectionManager, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, NetworkBufferPool networkBufferPool, TieredStorageConfiguration tieredStorageConfiguration, TieredStorageNettyServiceImpl tieredStorageNettyService) -
Uses of TieredStorageNettyServiceImpl in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle
Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle that return TieredStorageNettyServiceImpl Modifier and Type Method Description TieredStorageNettyServiceImplTieredResultPartitionFactory. getTieredStorageNettyService()Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle with parameters of type TieredStorageNettyServiceImpl Constructor Description TieredResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, org.apache.flink.util.function.SupplierWithException<BufferPool,IOException> bufferPoolFactory, TieredStorageProducerClient tieredStorageProducerClient, TieredStorageResourceRegistry tieredStorageResourceRegistry, TieredStorageNettyServiceImpl nettyService, List<TieredStorageMemorySpec> tieredStorageMemorySpecs, TieredStorageMemoryManager storageMemoryManager)TieredResultPartitionFactory(TieredStorageConfiguration tieredStorageConfiguration, TieredStorageNettyServiceImpl tieredStorageNettyService, TieredStorageResourceRegistry tieredStorageResourceRegistry)
-