import com.alibaba.fastjson.JSON;
import com.hundsun.quant.flow.model.Snapshot;
import org.apache.flink.api.common.serialization.DeserializationSchema;
import org.apache.flink.api.common.typeinfo.TypeInformation;
public class SnapshotSerializer implements DeserializationSchema<Snapshot> {
@Override
public Snapshot deserialize(byte[] message) {
return JSON.parseObject(new String(message), Snapshot.class);
}
@Override
public boolean isEndOfStream(Snapshot nextElement) {
return false;
}
@Override
public TypeInformation<Snapshot> getProducedType() {
return null;
}
}