211 messages

org.apache.flink.commits [All Lists]

2014 December [All Months]

Page 6 (Messages 126 to 150): 1 2 3 4 5 6 7 8 9

[06/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on element counters. Included respective policy helper and test cases. - mbal...@apache.org
[16/34] incubator-flink git commit: [streaming] Integrated the policy based windowing into DataStream and introduced WindowedDataStream to handle windowing helper. - mbal...@apache.org
[18/34] incubator-flink git commit: [streaming] Windowing API update + package refactor - mbal...@apache.org
[24/34] incubator-flink git commit: [streaming] Changed time based windowing policies to make lower boundary excluded and upper boundary included in the windows and adjusted policy test cases respectively. - mbal...@apache.org
[27/34] incubator-flink git commit: [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. - mbal...@apache.org
[29/34] incubator-flink git commit: [streaming] Renamed test cases for window and grouped window invokable to be consistent with the invokable names - mbal...@apache.org
incubator-flink git commit: [scala] Fix non-reuse copy in CaseClassSerializer - aljo...@apache.org
incubator-flink git commit: Enable flink-hbase module for hadoop1 build as well. - rmet...@apache.org
[1/4] incubator-flink git commit: [FLINK-1322] Make Scala API respect WriteMode set in Config - sew...@apache.org
[2/2] incubator-flink git commit: [streaming] Basic support reading from local and distributed file systems in readTextFile methods - mbal...@apache.org
[1/5] incubator-flink git commit: [Java API] Fix equality checks on PojoTypeInfo - sew...@apache.org
[4/5] incubator-flink git commit: [FLINK-610] Replace Avro by Kryo as the GenericType serializer - mbal...@apache.org
[74/82] [abbrv] incubator-flink git commit: Change integration tests to reuse cluster in order to save startup and shutdown time. - troh...@apache.org
[04/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[14/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[16/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[24/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[27/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[32/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[39/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[40/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[41/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[42/82] [abbrv] incubator-flink git commit: Moved WebInfoServer and WebInterfaceServer resources into resource folders of respective projects. Jetty uses the jar as base directory. - troh...@apache.org
[62/82] [abbrv] incubator-flink git commit: Fixed JobManagerITCase to properly wait for task managers to deregister their tasks. Replaced the scheduler's execution service with akka's futures. Introduced TestStreamEnvironment to use ForkableFlinkMiniClus - troh...@apache.org
[4/6] incubator-flink git commit: [dist] Updated the assembly of the examples subdirectory - mbal...@apache.org

Page 6 (Messages 126 to 150): 1 2 3 4 5 6 7 8 9