Uses of Interface
org.apache.flink.runtime.io.network.TaskEventPublisher

Packages that use TaskEventPublisher

Package	Description
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.netty
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.shuffle

Uses of TaskEventPublisher in org.apache.flink.runtime.io.network

Classes in org.apache.flink.runtime.io.network that implement TaskEventPublisher

Modifier and Type	Class and Description
class	TaskEventDispatcher The task event dispatcher dispatches events flowing backwards from a consuming task to the task producing the consumed result.

Uses of TaskEventPublisher in org.apache.flink.runtime.io.network.netty

Constructors in org.apache.flink.runtime.io.network.netty with parameters of type TaskEventPublisher

Constructor and Description
NettyConnectionManager(ResultPartitionProvider partitionProvider, TaskEventPublisher taskEventPublisher, NettyConfig nettyConfig)

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

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

Modifier and Type	Field and Description
protected TaskEventPublisher	SingleInputGateFactory.taskEventPublisher

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

Constructor and Description
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, Counter numBytesIn, Counter numBuffersIn)
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn)
SingleInputGateFactory(ResourceID taskExecutorResourceId, NettyShuffleEnvironmentConfiguration networkConfig, ConnectionManager connectionManager, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, NetworkBufferPool networkBufferPool)

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

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

Modifier and Type	Method and Description
TaskEventPublisher	ShuffleEnvironmentContext.getEventPublisher()

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

Constructor and Description
ShuffleEnvironmentContext(Configuration configuration, ResourceID taskExecutorResourceId, MemorySize networkMemorySize, boolean localCommunicationOnly, InetAddress hostAddress, TaskEventPublisher eventPublisher, MetricGroup parentMetricGroup, Executor ioExecutor)