- 05 12月, 2014 27 次提交
-
-
由 Jonas Traub (powibol) 提交于
[streaming] Extended test cases for grouped window invokable to cover usage of central eviction policies
-
由 Jonas Traub (powibol) 提交于
[streaming] Renamed test cases for window and grouped window invokable to be consistent with the invokable names
-
由 Gyula Fora 提交于
-
由 ghermann 提交于
-
由 Gyula Fora 提交于
-
由 Jonas Traub (powibol) 提交于
[streaming] Changed time based windowing policies to make lower boundary excluded and upper boundary included in the windows and adjusted policy test cases respectively.
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
由 Jonas Traub (powibol) 提交于
-
由 Jonas Traub (powibol) 提交于
[streaming] Make all predefined policies cloneable and introduce an activating wrapper for cloneable eviction policies
-
由 Jonas Traub (powibol) 提交于
[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.
-
由 Jonas Traub (powibol) 提交于
[streaming] Fixed windowing examples by removing manual setting of source parallelism [streaming] Extended streaming guide with a section about the new policy based windowing.
-
由 Jonas Traub (powibol) 提交于
-
由 Jonas Traub (powibol) 提交于
[streaming] Integrated the policy based windowing into DataStream and introduced WindowedDataStream to handle windowing helper.
-
由 Jonas Traub (powibol) 提交于
[streaming] Added cosine distance and Euclidean distance as examples for possible delta function implementations. Test cases are included as well. [streaming] Added policy helper for delta policies to provide a simpler API for such policies. [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.
-
由 Jonas Traub (powibol) 提交于
[streaming] Added abstract class ExtractionAwareDeltaFunction to enable easy extraction of data in pre-defined delta functions.
-
由 Jonas Traub (powibol) 提交于
[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)
-
由 Jonas Traub (powibol) 提交于
[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)
-
由 Jonas Traub (powibol) 提交于
-
由 Jonas Traub (powibol) 提交于
[streaming] Added extractor implementations for various extractions and conversions. (incl. test cases)
-
由 Jonas Traub (powibol) 提交于
[streaming] Created active trigger and eviction policies based on time. Included respective policy helper and test cases.
-
由 Jonas Traub (powibol) 提交于
[streaming] Introduced extractor interface to enable flexible handling of arbitrary input data types.
-
由 Jonas Traub (powibol) 提交于
[streaming] Created trigger and eviction policies based on element counters. Included respective policy helper and test cases.
-
由 Jonas Traub (powibol) 提交于
[streaming] Added interface for policy helpers. Such helpers will allow to use policy based windowing through a simpler API.
-
由 Jonas Traub (powibol) 提交于
[streaming] Introduced a new invokable to allow flexible windowing based on trigger and eviction policies. Additionally created all required policy interfaces.
-
- 04 12月, 2014 1 次提交
-
-
由 Robert Metzger 提交于
- Move some background on the most important configuration values into the configuration guide - Remove the term "UDF" because it is often being confused with UDFs in SQL - Fixe some typos
-
- 02 12月, 2014 1 次提交
-
-
由 Ufuk Celebi 提交于
This closes #244.
-
- 01 12月, 2014 3 次提交
-
-
由 Stephan Ewen 提交于
This closes #241
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
The code originates from https://github.com/apache/incubator-flink/pull/61. The pull request also contained code to add POJO support to the distinct() operator. This has already been implemented in earlier work
-
- 29 11月, 2014 3 次提交
-
-
由 Robert Metzger 提交于
This closes #233
-
由 Stephan Ewen 提交于
This closes #240.
-
由 Moritz Borgmann 提交于
This closes #242
-
- 28 11月, 2014 5 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 fpompermaier 提交于
-
由 Stephan Ewen 提交于
Add optional test for external sorting of case classes. Fix various warnings.
-
由 Shiva Teja Reddy 提交于
This closes #238
-