Re: [RichFlattMapfunction] Configuration File

Hi Simon, Great! I think this is only available in the DataSet API. Cheers, Max On Mon, May 23, 2016 at 2:23 PM, simon peyer wrote: > Hi Max > > Thanks a lot. > I found now this solution: > > Passing it as a Configuration object to single functions > > The example below shows how to pass the pa

Re: [RichFlattMapfunction] Configuration File

Hi Max Thanks a lot. I found now this solution: Passing it as a Configuration object to single functions The example below shows how to pass the parameters a

Re: [RichFlattMapfunction] Configuration File

Hi Simon, As Aljoscha said, the best way is to supply the configuration as class fields. Alternatively, if you overload the open(..) method, it should also show up in the Properties/Configuration tab on the Web interface. Cheers, Max On Mon, May 23, 2016 at 11:43 AM, simon peyer wrote: > Hi Alj

Re: [RichFlattMapfunction] Configuration File

Hi Aljoscha Thanks for your reply. Regarding question 2, the web dashboard does provide a properties section, besides ( Plan Timeline

Re: [RichFlattMapfunction] Configuration File

Hi Simon, regarding 1. yes, the value that you get from state_item.value() and that you set using state_item.update() is scoped to the key of the incoming element. regarding 2. the open(conf: Configuration) signature is legacy from how Functions used to work quite a while back. In the streaming AP

[RichFlattMapfunction] Configuration File

Hi folks I'm extending a RichFlatMapFunction in order to use states on a keyed stream. Concerning this i have two questions: 1. I have a var state_item: ValueState[Option[String]] as a local variable in this class. Initialized with state_item = getRuntimeContext.getState(new ValueStateDescript