Flink Parquet Writer
From last post, we learned if we want to have a streaming ETL in parquet format, we need to implement a flink parquet writer. So Let’s implement the Writer Interface.
Writer V1:
public class FlinkAvroParquetWriterV1<T> implements…
