Re: DataStream and DataStreamSource

2022-09-14 Thread Noel OConnor
Awesome, thanks for the info! much appreciated. On Wed, Sep 14, 2022 at 5:04 PM Jing Ge wrote: > > Hi, > > Welcome to the Flink community! > > A DataStreamSource is a DataStream. It is normally used as the starting point > of a DataStream. All related methods in StreamExecutionEnvironment that

Re: DataStream and DataStreamSource

2022-09-14 Thread Jing Ge
Hi, Welcome to the Flink community! A DataStreamSource is a DataStream. It is normally used as the starting point of a DataStream. All related methods in StreamExecutionEnvironment that create a DataStream return actually a DataStreamSource, because it is where a DataStream starts. Commonly, yo

DataStream and DataStreamSource

2022-09-14 Thread Noel OConnor
Hi, I'm new to flink and I'm trying to integrate it with apache pulsar. I've gone through the demos and I get how they work but one aspect that I can't figure out is what's the difference between a DataStream and a DataStreamSource. When would you use one over the other? cheers Noel