flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API
Date Sat, 25 Jul 2015 14:47:04 GMT
Gyula Fora created FLINK-2405:
---------------------------------

             Summary: Add stateful transformations using lambdas to the Streaming Scala API
                 Key: FLINK-2405
                 URL: https://issues.apache.org/jira/browse/FLINK-2405
             Project: Flink
          Issue Type: New Feature
          Components: Scala API, Streaming
            Reporter: Gyula Fora
            Priority: Minor


I propose to extend the Streaming Scala API methods (map, flatmap, filter etc) with versions
that take stateful functions as lambdas. This would allow for a nice functional way of defining
stateful transformations:

Example:
def mapWithState( fun: (I, Option[S]) => (O, Option[S]), stateByKey: Boolean = false)

The stateByKey optional flag allows the user to partition the state by key when applied on
a KeyedDataStream.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message