Re: callback by using process function

[Dawid Wysakowicz]

Hi,

I am sorry, but I think I don't fully get your question. Could you try
to rephrase it? Maybe an example could help.

Generally speaking the KeyedProcessFunction is scoped to a single key.
Whenever you access a state (MapState, ValueState, ... ) it keeps the
current value of that state for the current key.

Best,

Dawid

On 06/05/2021 12:30, Abdullah bin Omar wrote:
> Hi,
>
> According to [1] example section,
>
> (i) If we check the stored count of the last modification time against
> the previous timestamp count, then emit the count if they (count from
> last modification time) match with the previous timestamp count.
>
> Is there refere about checking the previous count? am I understanding
> correctly? help me to understand this part.
>
> (ii)  can the process function be used to look back the previous
> key/count?
>
> [1] 
> https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/operators/process_function/
> 
>
> Thank you
>



OpenPGP_signature
Description: OpenPGP digital signature

callback by using process function

[Abdullah bin Omar]

Hi,

According to [1] example section,

(i) If we check the stored count of the last modification time against the
previous timestamp count, then emit the count if they (count from last
modification time) match with the previous timestamp count.

Is there refere about checking the previous count? am I understanding
correctly? help me to understand this part.

(ii)  can the process function be used to look back the previous key/count?

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/operators/process_function/

Thank you