Apache Flink Statefun - broadcast state

[M Singh]

Hi:
I am working with Stateful Functions 3.2.0 using Java SDK.
I wanted to find out if there is a broadcast to all functions feature available 
in Stateful Functions just like broadcast process and keyed broadcast 
processing in Apache Flink.
Please let me know if there is any example/documentation.
Thanks

Jira issue assignment privs

[M Singh]

Hi:
I've created a JIRA issue 
https://issues.apache.org/jira/browse/FLINK-13542?filter=-2 and have submitted 
a pull request, but I am not able to assign it to myself.  I believe I had the 
privs earlier.  Can you please let me know how I can assign the issue to myself.
Thanks
Mans

Re: Guide for Flink Source/Sinks

[M Singh]

Thanks Till for the pointers.
Mans 

On Tuesday, May 10, 2016 1:07 AM, Till Rohrmann <trohrm...@apache.org> 
wrote:
 

 Hi Mans,there is no explicit guide for how to write a custom source/sink as 
far as I know. There is just a paragraph in the data sources section 
(https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/#data-sources).For
 sources you have to implement the SourceFunction interface for non parallel 
sources or the ParallelSourceFunction for parallel sources. If you need access 
to the RuntimeContext, then you should extend the RichParallelSourceFunction. 
Be aware, that you should always emit elements to the downstream operator when 
you hold the checkpoint lock. You emit and obtain the checkpoint lock from the 
SourceContext.For custom sinks you have to implement the SinkFunction or the 
ParallelSinkFunction.I hope this gets you started :-)Cheers,
Till​
On Mon, May 9, 2016 at 11:54 PM, M Singh <mans2si...@yahoo.com.invalid> wrote:

Hi Folks:
I am new to Flink and wanted to find out if there is a guide to how to create 
new sources/sinks for Flink.
I tried browsing through the documentation but did not find a single place with 
all the interfaces/etc required.
Thanks for your help.
Mans