Hi Vishal,
you're right: the FileSource itself doesn't provide these methods. But you
could get them through the DataStreamSource (which
implements SingleOutputStreamOperator and provides these two methods
[1,2]). It is returned by StreamExecutionEnvironment.fromSource [3].
fromSource would need th
I set names and uid for all my flink operators and have explicitly disabled
auto generation of uid to force developers in my team the same practice.
However, when using a file source, there's no option of providing it due to
which the job fails to start unless we enable auto generation. Am I doi
