- 10 12月, 2014 8 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 mbalassi 提交于
Renamed org.apache.flink.example package to org.apache.flink.examples Default data is provided from flink-java examples
-
由 mbalassi 提交于
[streaming] Documentation added for streaming java 8 support
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
-
- 09 12月, 2014 1 次提交
-
-
由 Stephan Ewen 提交于
-
- 08 12月, 2014 3 次提交
-
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
This closes #173
-
由 Fabian Hueske 提交于
[FLINK-1139] Added FinalizeOnMaster hook to run code after the last task of an OutputFormat completed
-
- 06 12月, 2014 4 次提交
-
-
由 Fabian Hueske 提交于
Made exceptions for license check plugin more fine-granular. This closes #250
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
Before, it was not doing a proper deep copy of the fields.
-
由 mbalassi 提交于
-
- 05 12月, 2014 24 次提交
-
-
由 Jonas Traub (powibol) 提交于
[streaming] Changed GroupedWindowInvokable to always delete groups in case they have an empty element buffer
-
由 Gyula Fora 提交于
[streaming] Updated streaming-guide to match recent api changes
-
由 Gyula Fora 提交于
-
由 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) 提交于
-