You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (Jira)" <ji...@apache.org> on 2019/10/10 14:11:00 UTC
[jira] [Commented] (FLINK-14356) Introduce "single-field" format to
(de)serialize message to a single field
[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948608#comment-16948608 ]
Timo Walther commented on FLINK-14356:
--------------------------------------
Alternatively, we could call it {{raw}} and really only support VARBINARY. I think this would simplify the design. What do you think?
> Introduce "single-field" format to (de)serialize message to a single field
> --------------------------------------------------------------------------
>
> 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)