Hi Soheil,
I think I knew what you meant by passing a function's name B to another
method A: assuming in function "A" you are trying to dynamically load
another function "B" based on either (1) some characteristic of the message
in your data stream, or (2) some configuration during start up.
And I
Hi Soheil,
What do you mean by "give it a written function's name B" and "function A
will apply function B"? Do you mean function A override B?
Perhaps the DataStream api guide[1] may gives you some guidance.
Best, Hequn
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/datastream_a
Is it possible in Flink to write a method A that we can give it a
written function's name B and function A will apply function B to
DataStream?
