t;
> final DataStreamSource file = env.fromSource(source,
> WatermarkStrategy.*forMonotonousTimestamps*()
> .withTimestampAssigner(new WatermarkAssigner((Object input)
> -> System.*currentTimeMillis*())),"FileSource");
> file.print();
> }
>
>
>
: 26 October 2023 20:59
To: Kirti Dhar Upadhyay K
Cc: user@flink.apache.org
Subject: Re: CSV Decoder with AVRO schema generated Object
Hi Kirti,
What do you mean exactly by "Flink CSV Decoder"? Please provide a snippet of
the code that you are trying to execute.
To be honest, combining C
Hi Kirti,
What do you mean exactly by "Flink CSV Decoder"? Please provide a snippet
of the code that you are trying to execute.
To be honest, combining CSV with AVRO-generated classes sounds rather
strange and you might want to reconsider your approach.
As for a quick fix, using aliases in your r
