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 boolean isRunning = true;
@Override
public void run(SourceContextString out) throws Exception {
while (isRunning) {
out.collect(String.valueOf(Math.floor(Math.random() * 100)));
}
}
@Override
public void cancel() {
isRunning = false;
}
});
My question is how could I do this in a scala’s way. Should I need add the
same SourceFunction class ? or I can use a functional way with scala’s function
programming.
Many Thanks.
