[FLINK-37443] Add returns() method to DataStream V2 API for specifying output types with lambda expressions#26284

Open

nilmadhab wants to merge 10 commits intoapache:masterfrom

nilmadhab:FLINK-37443/add-returns-method-datastreamv2

Commits on Mar 11, 2025

Trying out using lambda function in dataStreamV2 tests
Nilmadhab Mondal
committed
Working in my sample app
Nilmadhab Mondal
committed
Adding requireNonNull and fix formatting
Nilmadhab Mondal
committed

Commits on Mar 13, 2025

reverting test changes
Nilmadhab Mondal
committed
Adding working example with OneInputStreamProcessFunction as lamdba and using .returns method
Nilmadhab Mondal
committed
mvn spotless:apply done
Nilmadhab Mondal
committed

Commits on Mar 27, 2025

Adding returns method in GlobalStream and KeyedPartitionStream
Nilmadhab Mondal
committed
Adding returns method in ProcessConfigurableAndGlobalStreamImpl and ProcessConfigurableAndKeyedPartitionStreamImpl
Nilmadhab Mondal
committed
mvn spotless:apply
Nilmadhab Mondal
committed
Using lambda methods leveraging the returns method
Nilmadhab Mondal
committed