{"push_id":539724516,"size":182,"distinct_size":182,"ref":"refs/heads/master","head":"c52f4cab709eed2c8b355b4c24f87ace987d8fa9","before":"858d1bccf957bf36c04ab011ec9a26933109086c","commits":[{"sha":"a677c7723db298343681ccdfb3135373a9b4f7e6","author":{"email":"78b721c5bdf8fa1e5c15c24f06246c493ee3b282@apache.org","name":"Robert Metzger"},"message":"[FLINK-1157] Document TaskManager slots and minor fixes.\n\n- Move some background on the most important configuration values into the configuration guide\n- Remove the term \"UDF\" because it is often being confused with UDFs in SQL\n- Fixe some typos","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/a677c7723db298343681ccdfb3135373a9b4f7e6"},{"sha":"36f1ee88cbadc21b185782026e6a6fc77d41b42a","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Introduced a new invokable to allow flexible windowing based on trigger and eviction policies. Additionally created all required policy interfaces.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/36f1ee88cbadc21b185782026e6a6fc77d41b42a"},{"sha":"93178aebb804e2e96a4e6ae7e016247a4e2d82c7","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Added interface for policy helpers. Such helpers will allow to use policy based windowing through a simpler API.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/93178aebb804e2e96a4e6ae7e016247a4e2d82c7"},{"sha":"d731b3b06bfb7d61b0464715f22482c34ad88ff6","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Created trigger and eviction policies based on element counters. Included respective policy helper and test cases.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/d731b3b06bfb7d61b0464715f22482c34ad88ff6"},{"sha":"40c3ae481f538cebe7ecb265a796474e07517eee","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Introduced extractor interface to enable flexible handling of arbitrary input data types.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/40c3ae481f538cebe7ecb265a796474e07517eee"},{"sha":"6f3bf576c68e1884393016ef46297236367522eb","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Created active trigger and eviction policies based on time. Included respective policy helper and test cases.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/6f3bf576c68e1884393016ef46297236367522eb"},{"sha":"05c15198c6cb3edaed206c67727e7a4d08ad216b","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Added extractor implementations for various extractions and conversions. (incl. test cases)","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/05c15198c6cb3edaed206c67727e7a4d08ad216b"},{"sha":"a6cc8afb89f61d6067f4ccf85b50a5899630346a","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Created trigger and eviction policies based on data punctuation. (incl. test cases)","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/a6cc8afb89f61d6067f4ccf85b50a5899630346a"},{"sha":"fb4a8396b113ee2e6b2543614f6210c44e0587d9","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Created tumbling eviction policy. This policy evicts always all tuples after a trigger occurred. It can be used to prevent doubled computation between trigger and eviction policies whenever tumbling windows are used. (includes test case)","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/fb4a8396b113ee2e6b2543614f6210c44e0587d9"},{"sha":"997d3e1e9af38f2af0a6e7476ad7c868ceb404d6","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Created trigger and eviction policies which calculate a delta between two data points using a given delta function. The policies evict/trigger in case the delta is higher than a specified threshold. (incl. test case and the interface for delta functions)","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/997d3e1e9af38f2af0a6e7476ad7c868ceb404d6"},{"sha":"b2636247616fe152f85b3afeb03da3fa15689b09","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Added abstract class ExtractionAwareDeltaFunction to enable easy extraction of data in pre-defined delta functions.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/b2636247616fe152f85b3afeb03da3fa15689b09"},{"sha":"4d586e7264194fc7fc8ca86df6e555b1e3205fac","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Added cosine distance and Euclidean distance as examples for possible delta function implementations. Test cases are included as well.\n\n[streaming] Added policy helper for delta policies to provide a simpler API for such policies.\n\n[streaming] Created ActiveEvictionPolicyWrapper. This eviction policy wrappes around a non-active policy and makes it active by forwarding notification on fake elements to the regular notification method.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/4d586e7264194fc7fc8ca86df6e555b1e3205fac"},{"sha":"542c66f7d31e05154140299a26751b8fcf0cee0c","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Integrated the policy based windowing into DataStream and introduced WindowedDataStream to handle windowing helper.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/542c66f7d31e05154140299a26751b8fcf0cee0c"},{"sha":"3f506835b6d2fbe13a91e74d34de82b584cddcd1","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Added test cases for the policy based windowing invokable.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/3f506835b6d2fbe13a91e74d34de82b584cddcd1"},{"sha":"3d11d5baea1513a819f189f199502fc3979336b8","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Created several examples for the usage of policy based windowing.\n\n[streaming] Fixed windowing examples by removing manual setting of source parallelism\n\n[streaming] Extended streaming guide with a section about the new policy based windowing.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/3d11d5baea1513a819f189f199502fc3979336b8"},{"sha":"cd7bfd31f7b09df4933c84b4131d0b220fadcb8d","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Introduced grouped windowing invokable, added required cloneable policy interfaces, and adjusted existing windowing invokable to make it usable together with the new grouped windowing invokable.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/cd7bfd31f7b09df4933c84b4131d0b220fadcb8d"},{"sha":"70079c1d49fb81336c8846e4058301bd1b6b6b8e","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Make all predefined policies cloneable and introduce an activating wrapper for cloneable eviction policies","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/70079c1d49fb81336c8846e4058301bd1b6b6b8e"},{"sha":"751f1017c5c79be71cfef7a0bdc6272ea48881dc","author":{"email":"44f878afe53efc66b76772bd845eb65944ed8232@s-traub.com","name":"Jonas Traub (powibol)"},"message":"[streaming] Adding unit tests for the grouped windowing invokable.","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/751f1017c5c79be71cfef7a0bdc6272ea48881dc"},{"sha":"f96ba06e0510690af8c44ae5ef09dda15d2e1ff4","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] New windowing API merge and cleanup + several minor fixes","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/f96ba06e0510690af8c44ae5ef09dda15d2e1ff4"},{"sha":"55ee64f6c9824d51922fe4a8fb1435030925b110","author":{"email":"837d42e09a86de23c66ba40f44e2a3669b2ddc62@apache.org","name":"Gyula Fora"},"message":"[streaming] Extractor requirement removed for custom timestamp windowing","distinct":true,"url":"https://api.github.com/repos/knub/incubator-flink/commits/55ee64f6c9824d51922fe4a8fb1435030925b110"}]}