Hi Team, Could you please provide a sample for Enabling Compression (Snappy) of Avro: DataStream[GenericRecord]
AvroWriters.forGenericRecord(schema) Regards, Vijay
- [Compression] Flink DataStream[GenericRecord] Avrowr... Vijayendra Yadav
- Re: [Compression] Flink DataStream[GenericRecor... Ravi Bhushan Ratnakar
- Re: [Compression] Flink DataStream[GenericR... Ravi Bhushan Ratnakar
- Re: [Compression] Flink DataStream[Gene... Vijayendra Yadav
- Re: [Compression] Flink DataStream[... Vijayendra Yadav
- Re: [Compression] Flink DataSt... Ravi Bhushan Ratnakar
- Re: [Compression] Flink Da... Vijayendra Yadav
