[jira] [Created] (FLINK-14356) Support some special RowDeserializationSchema and RowSerializationSchema

[Shang Yuanchun (Jira)]

jinfeng created FLINK-14356:
-------------------------------

             Summary: Support some special RowDeserializationSchema and RowSerializationSchema
                 Key: FLINK-14356
                 URL: https://issues.apache.org/jira/browse/FLINK-14356
             Project: Flink
          Issue Type: Improvement
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / API
            Reporter: jinfeng


I want to use flink sql to write kafka messages directly to hdfs. The serialization and deserialization of messages are not involved in the middle.  The bytes of the message directly convert the first field of Row.  However, the current RowSerializationSchema does not support the conversion of bytes to VARBINARY. Can we add some special RowSerializationSchema and RowDerializationSchema ? 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)