- 12 12月, 2014 5 次提交
-
-
由 Ufuk Celebi 提交于
- This commit introduces reference-counting to keep track of the InputChannel and OutputChannel instances, which share the same physical TCP connection. - When the logical channels are released, the reference count will reach 0 and the respective TCP connection can safely be closed. - Furthermore, the debug thread in the OutboundConnectionQueue is properly shut down and all queued buffers are freed when the channel is closed or an Exception occurs. This closes #255.
-
由 Robert Metzger 提交于
-
由 Robert Metzger 提交于
This commit is based on a diff by @fpompermaier (see https://github.com/apache/incubator-flink/pull/220). This closes #220
-
由 Aljoscha Krettek 提交于
This closes #262.
-
由 Aljoscha Krettek 提交于
This closes #261.
-
- 11 12月, 2014 1 次提交
-
-
由 Carsten Brandt 提交于
java complains about not expecting an interface here. Needs to be `implements` instead of `extends`. This closes #257
-
- 10 12月, 2014 10 次提交
-
-
由 Fabian Hueske 提交于
-
由 dukechain 提交于
This closes #194
-
由 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 16 次提交
-
-
由 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.
-