Uses of Class
org.apache.flink.util.SerializedValue
-
Packages that use SerializedValue Package Description org.apache.flink.api.common.accumulators org.apache.flink.util -
-
Uses of SerializedValue in org.apache.flink.api.common.accumulators
Method parameters in org.apache.flink.api.common.accumulators with type arguments of type SerializedValue Modifier and Type Method Description static Map<String,OptionalFailure<Object>>AccumulatorHelper. deserializeAccumulators(Map<String,SerializedValue<OptionalFailure<Object>>> serializedAccumulators, ClassLoader loader)Takes the serialized accumulator results and tries to deserialize them using the provided class loader.static Map<String,Object>AccumulatorHelper. deserializeAndUnwrapAccumulators(Map<String,SerializedValue<OptionalFailure<Object>>> serializedAccumulators, ClassLoader loader)Takes the serialized accumulator results and tries to deserialize them using the provided class loader, and then try to unwrap the value unchecked. -
Uses of SerializedValue in org.apache.flink.util
Subclasses of SerializedValue in org.apache.flink.util Modifier and Type Class Description classCompressedSerializedValue<T>An extension ofSerializedValuethat compresses the value after the serialization.Methods in org.apache.flink.util that return SerializedValue Modifier and Type Method Description static <T> SerializedValue<T>SerializedValue. fromBytes(byte[] serializedData)Constructs serialized value from serialized data.
-