[
https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948355#comment-16948355
]
Timo Walther commented on FLINK-14356:
--------------------------------------
+1 for this. It was also mentioned in some early [design documents
here|https://docs.google.com/document/d/1Yaxp1UJUFW-peGLt8EIidwKIZEWrrA-pznWLuvaH39Y/edit#heading=h.41fd6rs7b3cf]
named {{single-value}}. It would be cool if we could support INT, LONG,
STRING, BYTES, ... to cover the most important types. It should be possible to
specify big endian/little endian order and string de/encoding.
> 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
> Priority: Major
>
> 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)
