Java源码示例：org.apache.flink.api.common.typeutils.CompositeSerializer
示例1
@SuppressWarnings("unchecked")
@Override
protected CompositeSerializer<TtlValue<T>> createSerializerInstance(
PrecomputedParameters precomputed,
TypeSerializer<?> ... originalSerializers) {
Preconditions.checkNotNull(originalSerializers);
Preconditions.checkArgument(originalSerializers.length == 2);
return new TtlSerializer<>(precomputed, originalSerializers);
}
示例2
@SuppressWarnings("unchecked")
@Override
protected CompositeSerializer<ValueWithTs<?>> createSerializerInstance(
PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers) {
return new Serializer(precomputed, originalSerializers[0], originalSerializers[1]);
}
示例3
@SuppressWarnings("unchecked")
@Override
protected CompositeSerializer<TtlValue<T>> createSerializerInstance(
PrecomputedParameters precomputed,
TypeSerializer<?> ... originalSerializers) {
Preconditions.checkNotNull(originalSerializers);
Preconditions.checkArgument(originalSerializers.length == 2);
return new TtlSerializer<>(precomputed, originalSerializers);
}
示例4
@SuppressWarnings("unchecked")
@Override
protected CompositeSerializer<ValueWithTs<?>> createSerializerInstance(
PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers) {
return new Serializer(precomputed, originalSerializers[0], originalSerializers[1]);
}
示例5
@SuppressWarnings("unchecked")
@Override
protected CompositeSerializer<TtlValue<T>> createSerializerInstance(
PrecomputedParameters precomputed,
TypeSerializer<?> ... originalSerializers) {
Preconditions.checkNotNull(originalSerializers);
Preconditions.checkArgument(originalSerializers.length == 2);
return new TtlSerializer<>(precomputed, originalSerializers);
}
示例6
@SuppressWarnings("unchecked")
@Override
protected CompositeSerializer<ValueWithTs<?>> createSerializerInstance(
PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers) {
return new Serializer(precomputed, originalSerializers[0], originalSerializers[1]);
}
示例7
public static <T> TypeSerializer<T> unwrapTtlSerializer(TypeSerializer<?> valueSerializer) throws Exception {
Field f = CompositeSerializer.class.getDeclaredField("fieldSerializers");
f.setAccessible(true);
return (TypeSerializer<T>) ((TypeSerializer<Object>[]) f.get(valueSerializer))[1];
}
