Uses of Class
org.apache.flink.runtime.plugable.SerializationDelegate
-
Packages that use SerializationDelegate Package Description org.apache.flink.runtime.operators.shipping -
-
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 Description List<RecordWriter<SerializationDelegate<T>>>OutputCollector. getWriters()List of writers that are associated with this output collectorMethods in org.apache.flink.runtime.operators.shipping with parameters of type SerializationDelegate Modifier and Type Method Description intOutputEmitter. selectChannel(SerializationDelegate<T> record)Constructor parameters in org.apache.flink.runtime.operators.shipping with type arguments of type SerializationDelegate Constructor Description OutputCollector(List<RecordWriter<SerializationDelegate<T>>> writers, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer)Initializes the output collector with a set of writers.
-