Apache Flink - Side output time semantics for DataStream

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Apache Flink - Side output time semantics for DataStream

M Singh
Hi:

I wanted to find out what is the timestamp associated with the elements of a stream side output with different stream time characteristics.

Thanks

Man 
Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink - Side output time semantics for DataStream

M Singh
Hey Folks - Just wanted to see if there are any thoughts on this question.

Thanks
On Saturday, July 13, 2019, 09:33:15 PM EDT, M Singh <[hidden email]> wrote:


Hi:

I wanted to find out what is the timestamp associated with the elements of a stream side output with different stream time characteristics.

Thanks

Man 
Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink - Side output time semantics for DataStream

Biao Liu
In reply to this post by M Singh
Hi,

I'm not sure what you exactly mean. Could you describe more about your requirements?

M Singh <[hidden email]> 于2019年7月14日周日 上午9:33写道:
Hi:

I wanted to find out what is the timestamp associated with the elements of a stream side output with different stream time characteristics.

Thanks

Man 
Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink - Side output time semantics for DataStream

M Singh
Hi Biao:  Thanks for your response.

My question is that if i have streaming application and with timestamp assigned to the elements, and in one of the process functions I have side output, then there are two situations possible:
1. The side output is the same type as main stream.
2. The side output is different from the main stream.

In both the above scenarios - what is the timestamp associated with the elements in side output stream?  Is it the same as the element that produced the side output ?  

Thanks

Mans

On Friday, July 19, 2019, 02:37:57 AM EDT, Biao Liu <[hidden email]> wrote:


Hi,

I'm not sure what you exactly mean. Could you describe more about your requirements?

M Singh <[hidden email]> 于2019年7月14日周日 上午9:33写道:
Hi:

I wanted to find out what is the timestamp associated with the elements of a stream side output with different stream time characteristics.

Thanks

Man