Passing a custom SourceContext to a SourceFunction

Posted by Debasish Ghosh on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Passing-a-custom-SourceContext-to-a-SourceFunction-tp27861.html

Hi -

I have a custom SourceFunction ..

class MySourceFunction[T](data: Seq[T]) extends SourceFunction[T] {

  def run(ctx: SourceContext[T]): Unit = {

    data.foreach(d ⇒ ctx.collect(d))

  } 

}

When this function is run during job execution, the SourceContext that gets passed serializes the data. I would like to pass a mock SourceContext (similar to https://github.com/apache/flink/blob/master/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/ListSourceContext.java) in the run method. How do I do this ? Note I am not invoking the run method explicitly anywhere.

Any help will be appreciated.

regards.

--