Uses of Class
org.apache.flink.runtime.plugable.SerializationDelegate

Packages that use SerializationDelegate

Package	Description
org.apache.flink.runtime.operators.shipping
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.partitioner
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.table.runtime.partitioner

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

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

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

Methods in org.apache.flink.runtime.operators.shipping with parameters of type SerializationDelegate

Modifier and Type	Method and Description
int	OutputEmitter.selectChannel(SerializationDelegate<T> record)

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

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

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

Constructor parameters in org.apache.flink.streaming.runtime.io with type arguments of type SerializationDelegate

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

Uses of SerializationDelegate in org.apache.flink.streaming.runtime.partitioner

Methods in org.apache.flink.streaming.runtime.partitioner with parameters of type SerializationDelegate

Modifier and Type	Method and Description
int	GlobalPartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	BroadcastPartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record) Note: Broadcast mode could be handled directly for all the output channels in record writer, so it is no need to select channels via this method.
int	CustomPartitionerWrapper.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	ForwardForConsecutiveHashPartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	ShufflePartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	RescalePartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	RebalancePartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	KeyGroupStreamPartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	ForwardForUnspecifiedPartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)
int	ForwardPartitioner.selectChannel(SerializationDelegate<StreamRecord<T>> record)

Uses of SerializationDelegate in org.apache.flink.streaming.runtime.tasks

Methods in org.apache.flink.streaming.runtime.tasks that return types with arguments of type SerializationDelegate

Modifier and Type	Method and Description
static <OUT> RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>>	StreamTask.createRecordWriterDelegate(StreamConfig configuration, Environment environment)

Constructor parameters in org.apache.flink.streaming.runtime.tasks with type arguments of type SerializationDelegate

Constructor and Description
FinishedOperatorChain(StreamTask<OUT,OP> containingTask, RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)
OperatorChain(StreamTask<OUT,OP> containingTask, RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)
RegularOperatorChain(StreamTask<OUT,OP> containingTask, RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate)

Uses of SerializationDelegate in org.apache.flink.table.runtime.partitioner

Methods in org.apache.flink.table.runtime.partitioner with parameters of type SerializationDelegate

Modifier and Type	Method and Description
int	BinaryHashPartitioner.selectChannel(SerializationDelegate<StreamRecord<RowData>> record)