Uses of Class
org.apache.flink.runtime.io.network.api.writer.RecordWriter

Packages that use RecordWriter

Package	Description
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.shipping
org.apache.flink.streaming.runtime.io

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

Subclasses of RecordWriter in org.apache.flink.runtime.io.network.api.writer

Modifier and Type	Class and Description
class	BroadcastRecordWriter<T extends IOReadableWritable> A special record-oriented runtime result writer only for broadcast mode.
class	ChannelSelectorRecordWriter<T extends IOReadableWritable> A regular record-oriented runtime result writer.

Methods in org.apache.flink.runtime.io.network.api.writer that return RecordWriter

Modifier and Type	Method and Description
RecordWriter<T>	RecordWriterBuilder.build(ResultPartitionWriter writer)
RecordWriter<T>	NonRecordWriter.getRecordWriter(int outputIndex)
RecordWriter<T>	RecordWriterDelegate.getRecordWriter(int outputIndex) Returns the internal actual record writer instance based on the output index.
RecordWriter<T>	MultipleRecordWriters.getRecordWriter(int outputIndex)
RecordWriter<T>	SingleRecordWriter.getRecordWriter(int outputIndex)

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

Constructor and Description
SingleRecordWriter(RecordWriter<T> recordWriter)

Constructor parameters in org.apache.flink.runtime.io.network.api.writer with type arguments of type RecordWriter

Constructor and Description
MultipleRecordWriters(List<RecordWriter<T>> recordWriters)

Uses of RecordWriter in org.apache.flink.runtime.operators

Fields in org.apache.flink.runtime.operators with type parameters of type RecordWriter

Modifier and Type	Field and Description
protected List<RecordWriter<?>>	BatchTask.eventualOutputs The output writers for the data that this task forwards to the next task.

Method parameters in org.apache.flink.runtime.operators with type arguments of type RecordWriter

Modifier and Type	Method and Description
static void	BatchTask.clearWriters(List<RecordWriter<?>> writers)
static <T> Collector<T>	BatchTask.getOutputCollector(AbstractInvokable task, TaskConfig config, ClassLoader cl, List<RecordWriter<?>> eventualOutputs, int outputOffset, int numOutputs) Creates the Collector for the given task, as described by the given configuration.
static <T> Collector<T>	BatchTask.initOutputs(AbstractInvokable containingTask, ClassLoader cl, TaskConfig config, List<ChainedDriver<?,?>> chainedTasksTarget, List<RecordWriter<?>> eventualOutputs, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulatorMap) Creates a writer for each output.

Uses of RecordWriter in org.apache.flink.runtime.operators.shipping

Methods in org.apache.flink.runtime.operators.shipping that return types with arguments of type RecordWriter

Modifier and Type	Method and Description
List<RecordWriter<SerializationDelegate<T>>>	OutputCollector.getWriters() List of writers that are associated with this output collector

Constructor parameters in org.apache.flink.runtime.operators.shipping with type arguments of type RecordWriter

Constructor and Description
OutputCollector(List<RecordWriter<SerializationDelegate<T>>> writers, TypeSerializer<T> serializer) Initializes the output collector with a set of writers.

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

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

Constructor and Description
RecordWriterOutput(RecordWriter<SerializationDelegate<StreamRecord<OUT>>> recordWriter, TypeSerializer<OUT> outSerializer, OutputTag outputTag, StreamStatusProvider streamStatusProvider)