Alexander Fedulov created FLINK-33286:
-----------------------------------------

             Summary: DataGeneratorSource should support automatic return type 
detection
                 Key: FLINK-33286
                 URL: https://issues.apache.org/jira/browse/FLINK-33286
             Project: Flink
          Issue Type: Improvement
    Affects Versions: 1.17.1
            Reporter: Alexander Fedulov


Currently, DataGeneratorSource requires both GeneratorFunction<Long, OUT> and 
TypeInformation<OUT> to be passed during its construction. Given that the 
generator function has a fixed API, it should be possible to reliably extract 
the OUT type automatically for both lambda generator functions and for objects.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to