Yes I did. Sorry my bad.
On May 11, 2016 7:31 AM, "Aljoscha Krettek" wrote:
> I think Till mistyped, sinks are always parallel, you don't need the
> ParallelSinkFunction.
>
> On Tue, 10 May 2016 at 18:56 M Singh wrote:
>
> > Hi Till, Folks:
> > I found ParallelSourceFunction/RichParallelSourceFu
I think Till mistyped, sinks are always parallel, you don't need the
ParallelSinkFunction.
On Tue, 10 May 2016 at 18:56 M Singh wrote:
> Hi Till, Folks:
> I found ParallelSourceFunction/RichParallelSourceFunctions in the
> flink-streaming-java_2.10 module (1.1-SNAPSHOT), but could not find
> Par
Hi Till, Folks:
I found ParallelSourceFunction/RichParallelSourceFunctions in the
flink-streaming-java_2.10 module (1.1-SNAPSHOT), but could not find
ParallelSinkFunction et. al. Am I missing anything ?
Thanks
On Tuesday, May 10, 2016 5:31 AM, M Singh
wrote:
Thanks Till for the poi
Thanks Till for the pointers.
Mans
On Tuesday, May 10, 2016 1:07 AM, Till Rohrmann
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-m
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
