java.io.DataInputStream to org.apache.flink.core.memory.DataInputViewStreamWrapper