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)
