是不是只能用Wrapper包装一下,不该用继承?
public interface DataMessage {
Map<String, String> getData();
}
public class JsonSerializationSchema<T> implements SerializationSchema<T> {
@Override
public byte[] serialize(T element) {
try {
return mapper.writeValueAsBytes(element);
} catch (JsonProcessingException e) {
throw new RuntimeException(
String.format("Could not serialize value '%s'.", element), e);
}
}
}
public class DataMessageJsonSerializationSchema extends JsonSerializationSchema<DataMessage> {
@Override
public byte[] serialize(DataMessage element) {
return super.serialize(element.getData()) ///?? 这里想使用父类的方法,应该怎么写呢?
}
}
--
FROM 123.123.40.*