flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Operators chaining as custom functions
Date Tue, 27 Jan 2015 13:37:32 GMT
Hi guys,

I'd like to know whether it is possible or not save a chain of operators as
a custom function.
For example, If I have a DataSet transformation composed by a map followed
by a reduce (but this is a simple case, I could have a more complex
scenario), is it possible to save it as a custom function (eg. "myFunction"
=> map.reduce) so that I can call mydataset.myFunction() instead of
myDataset.map().reduce()?

Best,
Flavio

Mime
View raw message