Re: How to implement a "saveAsBinaryFile" function?

2020-01-18 Thread jelmer
I think you could also try saveAsHadoopFile with a custom output format like https://github.com/amutu/tdw/blob/master/qe/contrib/src/java/org/apache/hadoop/hive/contrib/fileformat/protobuf/mapred/ProtobufOutputFormat.java On Thu, 16 Jan 2020 at 09:34, Duan,Bing wrote: > Hi all: > > I read

Patch to produce messages with null body using console producer

2019-12-27 Thread jelmer
compacted kafka topic. So far the pull request has not received any attention. The patch is fairly minimal and does not break existing behaviour. Is there any chance someone could take a look at this? --Jelmer