Uses of Interface
org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter

Packages that use ResultPartitionWriter

Package	Description
org.apache.flink.runtime.execution
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.taskmanager
org.apache.flink.streaming.runtime.io

Uses of ResultPartitionWriter in org.apache.flink.runtime.execution

Methods in org.apache.flink.runtime.execution that return ResultPartitionWriter

Modifier and Type	Method and Description
ResultPartitionWriter[]	Environment.getAllWriters()
ResultPartitionWriter	Environment.getWriter(int index)

Uses of ResultPartitionWriter in org.apache.flink.runtime.io.network.api.writer

Fields in org.apache.flink.runtime.io.network.api.writer declared as ResultPartitionWriter

Modifier and Type	Field and Description
protected ResultPartitionWriter	RecordWriter.targetPartition

Constructors in org.apache.flink.runtime.io.network.api.writer with parameters of type ResultPartitionWriter

Constructor and Description
RecordWriter(ResultPartitionWriter writer)
RecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector)
RecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector, boolean flushAlways)

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

Classes in org.apache.flink.runtime.io.network.partition that implement ResultPartitionWriter

Modifier and Type	Class and Description
class	ResultPartition A result partition for data produced by a single task.

Uses of ResultPartitionWriter in org.apache.flink.runtime.taskmanager

Methods in org.apache.flink.runtime.taskmanager that return ResultPartitionWriter

Modifier and Type	Method and Description
ResultPartitionWriter[]	RuntimeEnvironment.getAllWriters()
ResultPartitionWriter	RuntimeEnvironment.getWriter(int index)

Constructors in org.apache.flink.runtime.taskmanager with parameters of type ResultPartitionWriter

Constructor and Description

RuntimeEnvironment(JobID jobId, JobVertexID jobVertexId, ExecutionAttemptID executionId, ExecutionConfig executionConfig, TaskInfo taskInfo, Configuration jobConfiguration, Configuration taskConfiguration, ClassLoader userCodeClassLoader, MemoryManager memManager, IOManager ioManager, BroadcastVariableManager bcVarManager, TaskStateManager taskStateManager, AccumulatorRegistry accumulatorRegistry, TaskKvStateRegistry kvStateRegistry, InputSplitProvider splitProvider, Map<String,Future<Path>> distCacheEntries, ResultPartitionWriter[] writers, InputGate[] inputGates, TaskEventDispatcher taskEventDispatcher, CheckpointResponder checkpointResponder, TaskManagerRuntimeInfo taskManagerInfo, TaskMetricGroup metrics, Task containingTask)

Uses of ResultPartitionWriter in org.apache.flink.streaming.runtime.io

Constructors in org.apache.flink.streaming.runtime.io with parameters of type ResultPartitionWriter

Constructor and Description
StreamRecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector, long timeout)
StreamRecordWriter(ResultPartitionWriter writer, ChannelSelector<T> channelSelector, long timeout, String taskName)