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

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.selectChannels(SerializationDelegate<T> record, int numberOfChannels)

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(StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> recordWriter, TypeSerializer<OUT> outSerializer, OutputTag outputTag, StreamStatusProvider streamStatusProvider)

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[]	RebalancePartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	BroadcastPartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	KeyGroupStreamPartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	ShufflePartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	GlobalPartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	RescalePartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	ForwardPartitioner.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)
int[]	CustomPartitionerWrapper.selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels)