结合 Flink 学习装饰者模式

shengjk1

发布于 2025-05-16 02:20:21

2800

代码可运行

文章被收录于专栏：码字搬砖码字搬砖

运行总次数：0

代码可运行

什么是装饰者模式

动态的将责任附加到对象上。若要扩展功能，装饰者提供了比继承更有弹性的替代方案。简单的理解就是通过包装来扩展功能，相比于继承，更有弹性

Flink 是如何实现观察者模式的

@Internal
public class KafkaDeserializationSchemaWrapper<T> implements KafkaDeserializationSchema<T> {

	private static final long serialVersionUID = 2651665280744549932L;

	private final DeserializationSchema<T> deserializationSchema;

	public KafkaDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema) {
		this.deserializationSchema = deserializationSchema;
	}

	@Override
	public T deserialize(ConsumerRecord<byte[], byte[]> record) throws Exception {
		return deserializationSchema.deserialize(record.value());
	}

	@Override
	public boolean isEndOfStream(T nextElement) {
		return deserializationSchema.isEndOfStream(nextElement);
	}

	@Override
	public TypeInformation<T> getProducedType() {
		return deserializationSchema.getProducedType();
	}
}

Flink 是通过 Wrapper 方法来实现的

public FlinkKafkaConsumer(Pattern subscriptionPattern, DeserializationSchema<T> valueDeserializer, Properties props) {
		this(null, subscriptionPattern, new KafkaDeserializationSchemaWrapper<>(valueDeserializer), props);
	}