[ 
https://issues.apache.org/jira/browse/FLINK-6141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328804#comment-17328804
 ] 

Flink Jira Bot commented on FLINK-6141:
---------------------------------------

This major issue is unassigned and itself and all of its Sub-Tasks have not 
been updated for 30 days. So, it has been labeled "stale-major". If this ticket 
is indeed "major", please either assign yourself or give an update. Afterwards, 
please remove the label. In 7 days the issue will be deprioritized.

> Add buffering service for stream operators
> ------------------------------------------
>
>                 Key: FLINK-6141
>                 URL: https://issues.apache.org/jira/browse/FLINK-6141
>             Project: Flink
>          Issue Type: Sub-task
>          Components: API / DataStream
>            Reporter: Aljoscha Krettek
>            Priority: Major
>              Labels: stale-major
>
> As mentioned in 
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-17+Side+Inputs+for+DataStream+API
>  we need a way of buffering incoming elements until a side input that is 
> required for processing them is ready.
> There has to be an implementation for non-keyed operators and for keyed 
> operators because in keyed operators we need to ensure that we store the 
> buffered elements in the correct key group when checkpointing.
> For the interface, I propose this:
> {code}
> @PublicEvolving
> public interface ElementBuffer<T, N> {
>       /**
>        * Adds the given element to the buffer for the given namespace.
>        */
>       void add(N namespace, T element);
>       /**
>        * Returns an {@code Iterable} over all buffered elements for the given 
> namespace.
>        */
>       Iterable<T> values(N namespace);
>       /**
>        * Clears all buffered elements for the given namespace. 
>        */
>       void clear(N namespace);
> }
> {code}
> {{AbstractStreamOperator}} would provide a method {{getElementBuffer()}} that 
> would return the appropriate implementation for a non-keyed or keyed operator.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to