package com.amazonaws.utils; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.flink.api.common.serialization.AbstractDeserializationSchema; import java.io.IOException; public class JsonDeserializationSchema<T> extends AbstractDeserializationSchema<T> { ObjectMapper objectMapper = new ObjectMapper(); private final Class<T> tClass; public JsonDeserializationSchema(Class<T> tClass) { super(tClass); this.tClass = tClass; } @Override public T deserialize(byte[] bytes) throws IOException { return objectMapper.readValue(bytes, tClass); } }