flink-commits mailing list archives: December 2014

Site index · List index
Message list1 · 2 · Next »Thread · Author · Date
rmetz...@apache.org incubator-flink git commit: [FLINK-984] Compiler tests for distinct(). Adopted the old code from @markus-h Mon, 01 Dec, 09:13
rmetz...@apache.org incubator-flink git commit: [Docs] Fix rendering issue and typo Mon, 01 Dec, 09:25
se...@apache.org incubator-flink git commit: [FLINK-1292] Allow for longer normalized keys when using composite keys Mon, 01 Dec, 17:39
u..@apache.org incubator-flink git commit: [Java API] [docs] Rephrase Javadoc of minBy/maxBy and link from min/max Mon, 01 Dec, 17:57
rmetz...@apache.org incubator-flink git commit: [FLINK-1157] Document TaskManager slots and minor fixes. Thu, 04 Dec, 09:00
mbala...@apache.org [01/34] incubator-flink git commit: [streaming] Added cosine distance and Euclidean distance as examples for possible delta function implementations. Test cases are included as well. Fri, 05 Dec, 17:26
mbala...@apache.org   [02/34] incubator-flink git commit: [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 Fri, 05 Dec, 17:26
mbala...@apache.org   [03/34] incubator-flink git commit: [streaming] Introduced extractor interface to enable flexible handling of arbitrary input data types. Fri, 05 Dec, 17:26
mbala...@apache.org   [04/34] incubator-flink git commit: [streaming] Added interface for policy helpers. Such helpers will allow to use policy based windowing through a simpler API. Fri, 05 Dec, 17:26
mbala...@apache.org   [05/34] incubator-flink git commit: [streaming] Introduced a new invokable to allow flexible windowing based on trigger and eviction policies. Additionally created all required policy interfaces. Fri, 05 Dec, 17:26
mbala...@apache.org   [06/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on element counters. Included respective policy helper and test cases. Fri, 05 Dec, 17:26
mbala...@apache.org   [07/34] incubator-flink git commit: [streaming] Created trigger and eviction policies based on data punctuation. (incl. test cases) Fri, 05 Dec, 17:26
mbala...@apache.org   [08/34] incubator-flink git commit: [streaming] Added extractor implementations for various extractions and conversions. (incl. test cases) Fri, 05 Dec, 17:26
mbala...@apache.org   [09/34] incubator-flink git commit: [streaming] Created active trigger and eviction policies based on time. Included respective policy helper and test cases. Fri, 05 Dec, 17:26
mbala...@apache.org   [10/34] incubator-flink git commit: [streaming] Added abstract class ExtractionAwareDeltaFunction to enable easy extraction of data in pre-defined delta functions. Fri, 05 Dec, 17:26
mbala...@apache.org   [11/34] incubator-flink git commit: [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. Fri, 05 Dec, 17:26
mbala...@apache.org   [12/34] incubator-flink git commit: [streaming] Adding unit tests for the grouped windowing invokable. Fri, 05 Dec, 17:26
mbala...@apache.org   [13/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes Fri, 05 Dec, 17:26
mbala...@apache.org   [14/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes Fri, 05 Dec, 17:26
mbala...@apache.org   [15/34] incubator-flink git commit: [streaming] New windowing API merge and cleanup + several minor fixes Fri, 05 Dec, 17:26
mbala...@apache.org   [16/34] incubator-flink git commit: [streaming] Integrated the policy based windowing into DataStream and introduced WindowedDataStream to handle windowing helper. Fri, 05 Dec, 17:26
mbala...@apache.org   [17/34] incubator-flink git commit: [streaming] Windowing API update + package refactor Fri, 05 Dec, 17:26
mbala...@apache.org   [18/34] incubator-flink git commit: [streaming] Windowing API update + package refactor Fri, 05 Dec, 17:26
mbala...@apache.org   [19/34] incubator-flink git commit: [streaming] Extractor requirement removed for custom timestamp windowing Fri, 05 Dec, 17:26
mbala...@apache.org   [20/34] incubator-flink git commit: [streaming] Added test cases for the policy based windowing invokable. Fri, 05 Dec, 17:26
mbala...@apache.org   [21/34] incubator-flink git commit: [streaming] Window cross API rework Fri, 05 Dec, 17:26
mbala...@apache.org   [22/34] incubator-flink git commit: [streaming] Window join api rework to support functional style Fri, 05 Dec, 17:26
mbala...@apache.org   [23/34] incubator-flink git commit: [streaming] Windowing helper API cleanup Fri, 05 Dec, 17:26
mbala...@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. Fri, 05 Dec, 17:26
mbala...@apache.org   [25/34] incubator-flink git commit: [streaming] Make all predefined policies cloneable and introduce an activating wrapper for cloneable eviction policies Fri, 05 Dec, 17:26
mbala...@apache.org   [26/34] incubator-flink git commit: [streaming] Created several examples for the usage of policy based windowing. Fri, 05 Dec, 17:26
mbala...@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. Fri, 05 Dec, 17:26
mbala...@apache.org   [28/34] incubator-flink git commit: [FLINK-1279] [streaming] Forward partitioning changed to use round-robin method Fri, 05 Dec, 17:26
mbala...@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 Fri, 05 Dec, 17:26
mbala...@apache.org   [30/34] incubator-flink git commit: [streaming] Central trigger/eviction API integration + invokable refactor Fri, 05 Dec, 17:26
mbala...@apache.org   [31/34] incubator-flink git commit: [streaming] Introduced central eviction policies in the grouped window invokable Fri, 05 Dec, 17:26
mbala...@apache.org   [32/34] incubator-flink git commit: [streaming] Changed GroupedWindowInvokable to always delete groups in case they have an empty element buffer Fri, 05 Dec, 17:26
mbala...@apache.org   [33/34] incubator-flink git commit: [streaming] Updated javadocs for new windowing semantics Fri, 05 Dec, 17:26
mbala...@apache.org   [34/34] incubator-flink git commit: [docs] [streaming] Windowing rework documentation update Fri, 05 Dec, 17:26
aljos...@apache.org incubator-flink git commit: [scala] Fix non-reuse copy in CaseClassSerializer Fri, 05 Dec, 18:21
aljos...@apache.org incubator-flink git commit: [scala] Fix TupleSerializerTest for corrected CaseClassSerializer Fri, 05 Dec, 19:28
ktzou...@apache.org svn commit: r1643429 - in /incubator/flink: ./ _includes/ _layouts/ css/ css/fonts/ css/main/ docs/ docs/0.6-incubating/ docs/0.6-incubating/api/ docs/0.6-incubating/api/java/ docs/0.6-incubating/api/java/org/ docs/0.6-incubating/api/java/org/apache/ d... Fri, 05 Dec, 21:02
ktzou...@apache.org svn commit: r1643435 - /incubator/flink/index.html Fri, 05 Dec, 21:07
fhue...@apache.org [1/2] incubator-flink git commit: [FLINK-1301] Added Apache license headers to Markdown, HTML, SVG, Python files. Made exceptions for license check plugin more fine-granular. Fri, 05 Dec, 21:33
fhue...@apache.org   [2/2] incubator-flink git commit: [FLINK-1301] Added Apache license headers to Markdown, HTML, SVG, Python files. Made exceptions for license check plugin more fine-granular. Fri, 05 Dec, 21:33
rmetz...@apache.org svn commit: r1643518 - in /incubator/flink: index.html site/downloads.html site/index.html Sat, 06 Dec, 10:58
fhue...@apache.org [1/2] incubator-flink git commit: [FLINK-1139] Added FinalizeOnMaster hook to run code after the last task of an OutputFormat completed Mon, 08 Dec, 09:30
fhue...@apache.org   [2/2] incubator-flink git commit: [FLINK-1139] Fixed HadoopOutputFormat to run with DOP > 1 Mon, 08 Dec, 09:30
fhue...@apache.org incubator-flink git commit: [FLINK-1139] Updated Hadoop Compatibility documentation Mon, 08 Dec, 09:38
ktzou...@apache.org svn commit: r1643799 - in /incubator/flink: blog/index.html site/blog/index.html site/blog/page2/index.html site/blog/page3/index.html site/downloads.html Mon, 08 Dec, 12:54
rmetz...@apache.org svn commit: r1643802 - /incubator/flink/site/downloads.html Mon, 08 Dec, 13:06
se...@apache.org incubator-flink git commit: [FLINK-1311] [optimizer] Correctly tag static/dynamic path for auxiliary nodes in iterations. Tue, 09 Dec, 14:45
mbala...@apache.org [1/5] incubator-flink git commit: Updated java 8 package to match flink-examples standards Wed, 10 Dec, 14:30
mbala...@apache.org   [2/5] incubator-flink git commit: [FLINK-1312] [streaming] OutputSelector changed to SAM-type to allow java 8 lambdas for splitting Wed, 10 Dec, 14:30
mbala...@apache.org   [3/5] incubator-flink git commit: [streaming] Java 8 WordCount example added for streaming Wed, 10 Dec, 14:30
mbala...@apache.org   [4/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas Wed, 10 Dec, 14:30
mbala...@apache.org   [5/5] incubator-flink git commit: [FLINK-1161] [streaming] Streaming API type handling rework to support java 8 lambdas Wed, 10 Dec, 14:30
se...@apache.org [1/4] incubator-flink git commit: [FLINK-1316] [web client] Fix plan display for nodes referenced from multiple closures. Wed, 10 Dec, 14:50
se...@apache.org   [2/4] incubator-flink git commit: [FLINK-1315] [optimizer] Fix bug in branch tracking logic. Wed, 10 Dec, 14:50
se...@apache.org   [3/4] incubator-flink git commit: [FLINK-1315] [optimizer] Extra test reproducing the IllegalStateException bug in bulk iterations. Wed, 10 Dec, 14:50
se...@apache.org   [4/4] incubator-flink git commit: [java8] Fix pom.xml to properly work with Eclipse m2e Wed, 10 Dec, 14:50
fhue...@apache.org [1/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional Wed, 10 Dec, 15:50
fhue...@apache.org   [2/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional Wed, 10 Dec, 15:50
fhue...@apache.org   [3/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional Wed, 10 Dec, 15:50
fhue...@apache.org   [4/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional Wed, 10 Dec, 15:50
fhue...@apache.org   [5/6] incubator-flink git commit: [FLINK-1040] Make types() call in projections optional Wed, 10 Dec, 15:50
fhue...@apache.org   [6/6] incubator-flink git commit: [FLINK-1040] Updated JavaDocs and removed deprecated types() calls from examples and tests Wed, 10 Dec, 15:50
ktzou...@apache.org svn commit: r1644497 - /incubator/flink/index.html Wed, 10 Dec, 17:59
rmetz...@apache.org incubator-flink git commit: Fixed java quickstart example Wed, 10 Dec, 20:16
u..@apache.org incubator-flink git commit: [scala] Add withParameters() support for sinks/sources Thu, 11 Dec, 18:16
u..@apache.org incubator-flink git commit: [FLINK-1310] Change ClosureCleaner Logging to DEBUG Thu, 11 Dec, 18:30
rmetz...@apache.org incubator-flink git commit: Enable flink-hbase module for hadoop1 build as well. Fri, 12 Dec, 09:37
rmetz...@apache.org incubator-flink git commit: [FLINK-1302] Make JDBCInputFormat implement the NonParallelInput interface Fri, 12 Dec, 10:38
u..@apache.org incubator-flink git commit: [FLINK-998] Close TCP connections after destroying logical channels Fri, 12 Dec, 13:17
aljos...@apache.org incubator-flink git commit: Exclude docs/_site/** from License Check Fri, 12 Dec, 13:44
fhue...@apache.org incubator-flink git commit: [FLINK-1287] LocalizableSplitAssigner prefers splits with less degrees of freedom Fri, 12 Dec, 14:57
fhue...@apache.org incubator-flink git commit: [FLINK-1208] Enable CsvInputFormats to ignore invalid lines and lines starting with comments Fri, 12 Dec, 15:50
se...@apache.org incubator-flink git commit: [FLINK-1324] [runtime] Trailing data is cached before the local input strategies are closed. Sun, 14 Dec, 15:40
se...@apache.org [1/4] incubator-flink git commit: [FLINK-1322] Make Scala API respect WriteMode set in Config Sun, 14 Dec, 22:26
se...@apache.org   [2/4] incubator-flink git commit: [scala] Change ScalaAggregateOperator to use TypeSerializer Sun, 14 Dec, 22:26
se...@apache.org   [3/4] incubator-flink git commit: [misc] Fix/suppress various compiler warnings. Sun, 14 Dec, 22:26
se...@apache.org   [4/4] incubator-flink git commit: [FLINK-1305] [FLINK-1304] Test for HadoopInputWrapper and NullWritable support Sun, 14 Dec, 22:26
fhue...@apache.org [1/2] incubator-flink git commit: [FLINK-1307] Excluded directories that match the file-filter from recursive descent. Mon, 15 Dec, 11:12
fhue...@apache.org   [2/2] incubator-flink git commit: [FLINK-1307] Allow file input from nested directory structure Mon, 15 Dec, 11:12
fhue...@apache.org incubator-flink git commit: Fixes broken code highlighting in documentation Mon, 15 Dec, 13:55
se...@apache.org incubator-flink git commit: [FLINK-1327] [core] Fix wrapping of MemorySegments in ByteBuffers Mon, 15 Dec, 16:57
mbala...@apache.org [1/2] incubator-flink git commit: [streaming] ReadTextFile re-implemented as RichFunction and cleanup Mon, 15 Dec, 22:07
mbala...@apache.org   [2/2] incubator-flink git commit: [streaming] Basic support reading from local and distributed file systems in readTextFile methods Mon, 15 Dec, 22:07
u..@apache.org incubator-flink git commit: [Runtime] [Tests] Remove flaky check in LocalInstanceManagerTest Tue, 16 Dec, 16:44
u..@apache.org incubator-flink git commit: [Distributed runtime] Fail task if execution state update is unsuccessful Tue, 16 Dec, 16:48
se...@apache.org [1/5] incubator-flink git commit: [Java API] Fix equality checks on PojoTypeInfo Tue, 16 Dec, 21:24
se...@apache.org   [2/5] incubator-flink git commit: [APIs] Add ExecutionConfig Tue, 16 Dec, 21:24
se...@apache.org   [3/5] incubator-flink git commit: [FLINK-1325] [Java API] Add Java ClosureCleaner Tue, 16 Dec, 21:24
se...@apache.org   [4/5] incubator-flink git commit: [FLINK-1325] [Java API] Minor cleanups on the ClosureCleaner Tue, 16 Dec, 21:24
se...@apache.org   [5/5] incubator-flink git commit: Bump version to 0.9-incubating-SNAPSHOT Tue, 16 Dec, 21:24
se...@apache.org Git Push Summary Tue, 16 Dec, 21:24
Message list1 · 2 · Next »Thread · Author · Date
Box list
Oct 2021288
Sep 2021700
Aug 2021786
Jul 2021537
Jun 2021478
May 2021486
Apr 2021844
Mar 2021587
Feb 2021440
Jan 2021464
Dec 2020617
Nov 20201845
Oct 20201078
Sep 2020763
Aug 2020577
Jul 2020671
Jun 20201241
May 20201300
Apr 2020778
Mar 2020671
Feb 2020552
Jan 2020552
Dec 2019699
Nov 2019636
Oct 2019425
Sep 2019378
Aug 2019788
Jul 2019879
Jun 2019559
May 2019549
Apr 2019325
Mar 2019388
Feb 2019612
Jan 2019553
Dec 2018339
Nov 2018690
Oct 2018600
Sep 2018487
Aug 2018448
Jul 2018599
Jun 2018236
May 2018525
Apr 2018365
Mar 2018538
Feb 2018606
Jan 2018405
Dec 2017177
Nov 2017468
Oct 2017356
Sep 2017219
Aug 2017263
Jul 2017462
Jun 2017321
May 2017729
Apr 2017307
Mar 2017394
Feb 2017310
Jan 2017807
Dec 2016417
Nov 2016314
Oct 2016524
Sep 2016371
Aug 2016522
Jul 2016290
Jun 2016252
May 2016217
Apr 2016312
Mar 2016335
Feb 2016514
Jan 2016272
Dec 2015147
Nov 2015352
Oct 2015476
Sep 2015310
Aug 2015328
Jul 2015350
Jun 2015373
May 2015339
Apr 2015399
Mar 2015397
Feb 2015422
Jan 2015334
Dec 2014211
Nov 2014170
Oct 2014186
Sep 2014307
Aug 2014276
Jul 2014291
Jun 2014270