[ https://issues.apache.org/jira/browse/FLINK-11427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16752126#comment-16752126 ]
Yun Tang commented on FLINK-11427: ---------------------------------- [~zjuguanghu] I just have a curious question which is a bit independent of this topic. Since Flink would treat protobuf message as {{GenericType}} not {{PojoType}}, how you guys use protobuf message when using field names, just as Flink's table API did below? {noformat} dataSet.join(another).where("name").equalTo("personName") {noformat} Or just use datastream api, and called {{getter}} of protobuf messages? > Protobuf parquet writer implementation > -------------------------------------- > > Key: FLINK-11427 > URL: https://issues.apache.org/jira/browse/FLINK-11427 > Project: Flink > Issue Type: Improvement > Components: Formats > Reporter: Guang Hu > Priority: Trivial > > Right now only ParquetAvroWriters exist to create ParquetWriterFactory. We > want to implement a protobuf ParquetProtoWriters to create > ParquetWriterFactory. I am happy to submit a PR if this approach sounds good > . -- This message was sent by Atlassian JIRA (v7.6.3#76005)