There is no separate Scala SourceFunction interface or similar
convenience interfaces, so you'll have to work against the Java version.
On 12/04/2019 09:07, hai wrote:
Hello:
Is there a example or best practise code of flink’s source of Scala
language, I found one example on official code
Hello:
Is there a example or best practise code of flink’s source of Scala language,
I found one example on official code’s HBaseWriteStreamExample:
DataStreamString dataStream = env.addSource(new SourceFunctionString() {
private static final long serialVersionUID = 1L;
private volatile boolea
