Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
static BoundedBlockingSubpartitionType |
BoundedBlockingSubpartitionType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BoundedBlockingSubpartitionType[] |
BoundedBlockingSubpartitionType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
ResultPartitionFactory(ResultPartitionManager partitionManager,
FileChannelManager channelManager,
BufferPoolFactory bufferPoolFactory,
BatchShuffleReadBufferPool batchShuffleReadBufferPool,
ScheduledExecutorService batchShuffleReadIOExecutor,
BoundedBlockingSubpartitionType blockingSubpartitionType,
int configuredNetworkBuffersPerChannel,
int floatingNetworkBuffersPerGate,
int networkBufferSize,
boolean batchShuffleCompressionEnabled,
String compressionCodec,
int maxBuffersPerChannel,
int sortShuffleMinBuffers,
int sortShuffleMinParallelism,
boolean sslEnabled,
int maxOverdraftBuffersPerGate) |
Modifier and Type | Method and Description |
---|---|
BoundedBlockingSubpartitionType |
NettyShuffleEnvironmentConfiguration.getBlockingSubpartitionType() |
Constructor and Description |
---|
NettyShuffleEnvironmentConfiguration(int numNetworkBuffers,
int networkBufferSize,
int partitionRequestInitialBackoff,
int partitionRequestMaxBackoff,
int networkBuffersPerChannel,
int floatingNetworkBuffersPerGate,
java.time.Duration requestSegmentsTimeout,
boolean isNetworkDetailedMetrics,
NettyConfig nettyConfig,
String[] tempDirs,
BoundedBlockingSubpartitionType blockingSubpartitionType,
boolean batchShuffleCompressionEnabled,
String compressionCodec,
int maxBuffersPerChannel,
long batchShuffleReadMemoryBytes,
int sortShuffleMinBuffers,
int sortShuffleMinParallelism,
BufferDebloatConfiguration debloatConfiguration,
int maxNumberOfConnections,
boolean connectionReuseEnabled,
int maxOverdraftBuffersPerGate) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.