flink git commit: [FLINK-1458] Allow Interfaces and abstract types in TypeExtractor

: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon Feb 2 16:08:18 2015 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Thu Feb 5 12:00:59 2015 +0100 -- .../flink/api/java/typeutils/TypeExtractor.java

flink git commit: [hotfix] Also use java closure cleaner on grouped operations

-us.apache.org/repos/asf/flink/tree/d62ab475 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d62ab475 Branch: refs/heads/master Commit: d62ab475331cac9d870a563da4f5dc091005b2c1 Parents: 5634ee2 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Thu Jan 15 11:46:53 2015 +0100 Committer

flink git commit: [hotfix] Fix missing guava dependency of flink-tests

Branch: refs/heads/release-0.8 Commit: 6afa4ba6e06084a7883be0d97cade57ebd8269ec Parents: cd2f88a Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon Feb 9 17:10:54 2015 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Mon Feb 9 17:46:44 2015 +0100

flink git commit: [hotfix] Fix missing guava dependency of flink-tests

: refs/heads/master Commit: 6ddfcb402b1fa0ec185f0d924c234411c47c4fd7 Parents: c1e1aca Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon Feb 9 17:10:54 2015 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Mon Feb 9 17:10:54 2015 +0100

[2/2] flink git commit: [FLINK-1463] Fix stateful/stateless Serializers and Comparators

: 7bc78cbf97d341ebfed32fdfe20f21e4d146a869 Parents: 2f16ca2 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri Jan 30 16:43:31 2015 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Mon Feb 9 13:19:32 2015 +0100

[1/2] flink git commit: [FLINK-1463] Fix stateful/stateless Serializers and Comparators

Repository: flink Updated Branches: refs/heads/master 2f16ca2db - 7bc78cbf9 http://git-wip-us.apache.org/repos/asf/flink/blob/7bc78cbf/flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/types/StringPairSerializer.java

[3/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API

://git-wip-us.apache.org/repos/asf/flink/commit/8b3805ba Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8b3805ba Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8b3805ba Branch: refs/heads/master Commit: 8b3805ba5905c3d84f3e0631bc6090a618df8e90 Parents: 7bc78cb Author: Aljoscha Krettek

[1/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API

Repository: flink Updated Branches: refs/heads/master 7bc78cbf9 - 8b3805ba5 http://git-wip-us.apache.org/repos/asf/flink/blob/8b3805ba/flink-staging/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapreduce/example/WordCount.java

[1/2] flink git commit: [FLINK-1463] Fix stateful/stateless Serializers and Comparators

Repository: flink Updated Branches: refs/heads/release-0.8 91382bb8c - 02b6f85fe http://git-wip-us.apache.org/repos/asf/flink/blob/02b6f85f/flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala

[1/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API

Repository: flink Updated Branches: refs/heads/release-0.8 944e2e3d5 - cd2f88afd http://git-wip-us.apache.org/repos/asf/flink/blob/cd2f88af/flink-java/src/test/java/org/apache/flink/api/java/hadoop/mapreduce/HadoopInputFormatTest.java

[3/3] flink git commit: [FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API

://git-wip-us.apache.org/repos/asf/flink/commit/cd2f88af Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cd2f88af Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cd2f88af Branch: refs/heads/release-0.8 Commit: cd2f88afdad4c9eb2cd141eb3283d2e0084b2527 Parents: 944e2e3 Author: Aljoscha

[1/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

Repository: flink Updated Branches: refs/heads/master 6b402f43d - 7407076d3 http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/temporaloperator/StreamJoinOperator.java

[3/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-java/src/test/java/org/apache/flink/api/common/operators/base/CoGroupOperatorCollectionTest.java -- diff --git

[5/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

: 6b402f4 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Nov 26 13:27:06 2014 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Tue Feb 10 13:15:03 2015 +0100 -- .../compiler/postpass

[4/5] flink git commit: [FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.

http://git-wip-us.apache.org/repos/asf/flink/blob/7407076d/flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java -- diff --git

flink git commit: [hotfix] [doc] Fix DataSet type in readCsvFile example

-us.apache.org/repos/asf/flink/tree/b13c9a7d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b13c9a7d Branch: refs/heads/master Commit: b13c9a7dd7d366123cd737cd2706234eb72c2a5d Parents: 1b42b62 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Thu Mar 26 11:21:30 2015 +0100 Committer

[12/12] flink git commit: [FLINK-947] Add parser to Expression API for exposing it to Java

/repos/asf/flink/diff/d7d9b639 Branch: refs/heads/master Commit: d7d9b639025a74b322b51e5a35f656c57fa28fc6 Parents: 659ddc0 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri Mar 6 11:53:48 2015 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Sun Mar 29 12:27:53

[03/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/codegen/GenerateBinaryResultAssembler.scala -- diff --git

[07/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-expressions/src/main/scala/org/apache/flink/api/expressions/tree/arithmetic.scala -- diff --git

[09/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c9519c8d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c9519c8d Branch: refs/heads/master Commit: c9519c8d6c869d2bfab186e449f0ad2b62484805 Parents: d7d9b63 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Mar 18 14:44

[04/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-table/src/main/scala/org/apache/flink/api/scala/table/DataSetConversions.scala -- diff --git

[08/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-expressions/src/main/scala/org/apache/flink/api/expressions/codegen/ExpressionCodeGenerator.scala -- diff --git

[05/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-expressions/src/test/scala/org/apache/flink/api/scala/expressions/test/AggregationsITCase.scala -- diff --git

[11/12] flink git commit: [FLINK-947] Add parser to Expression API for exposing it to Java

http://git-wip-us.apache.org/repos/asf/flink/blob/d7d9b639/flink-staging/flink-expressions/src/test/java/org/apache/flink/api/java/expressions/test/SelectITCase.java -- diff --git

[06/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-expressions/src/main/scala/org/apache/flink/api/scala/expressions/package.scala -- diff --git

[02/12] flink git commit: [FLINK-1623] Rename Expression API to Table API

http://git-wip-us.apache.org/repos/asf/flink/blob/c9519c8d/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/typeinfo/RenameOperator.scala -- diff --git

[10/12] flink git commit: [FLINK-947] Add parser to Expression API for exposing it to Java

http://git-wip-us.apache.org/repos/asf/flink/blob/d7d9b639/flink-staging/flink-expressions/src/test/scala/org/apache/flink/api/scala/expressions/test/GroupedAggreagationsITCase.scala -- diff --git

flink git commit: [FLINK-1769] Fix deploy bug caused by ScalaDoc aggregation

-us.apache.org/repos/asf/flink/tree/2d373d88 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2d373d88 Branch: refs/heads/master Commit: 2d373d88a733a71dcba21e64401e98624fcf9547 Parents: 83db1db Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Mar 25 14:50:40 2015 +0100 Committer

flink git commit: [FLINK-1255] Add FAQ entry about Scala API TypeInformation

-us.apache.org/repos/asf/flink/tree/2bdfd88e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2bdfd88e Branch: refs/heads/master Commit: 2bdfd88eb1fabd0e93bd6293213e7157ed9b1437 Parents: e868d59 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon Feb 23 16:35:17 2015 +0100 Committer

[6/6] flink git commit: [FLINK-947] Add a declarative Expression API

/e868d596 Branch: refs/heads/master Commit: e868d59611126795d284d66b9c5674a1f61a90a1 Parents: 98da559 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Oct 1 13:12:18 2014 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Mon Feb 23 13:09:08 2015 +0100

[3/6] flink git commit: [FLINK-947] Add a declarative Expression API

http://git-wip-us.apache.org/repos/asf/flink/blob/e868d596/flink-staging/flink-expressions/src/main/scala/org/apache/flink/examples/scala/TPCHQuery3Expression.scala -- diff --git

[4/6] flink git commit: [FLINK-947] Add a declarative Expression API

http://git-wip-us.apache.org/repos/asf/flink/blob/e868d596/flink-staging/flink-expressions/src/main/scala/org/apache/flink/api/expressions/tree/fieldExpression.scala -- diff --git

[3/4] flink git commit: [FLINK-1788] [table] Make logical plans transformable

http://git-wip-us.apache.org/repos/asf/flink/blob/2d55cf0d/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/ExtractEquiJoinFields.scala -- diff --git

[2/4] flink git commit: [FLINK-1788] [table] Make logical plans transformable

http://git-wip-us.apache.org/repos/asf/flink/blob/2d55cf0d/flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/runtime/ExpressionFilterFunction.scala -- diff --git

[4/4] flink git commit: [FLINK-1788] [table] Make logical plans transformable

/flink/diff/2d55cf0d Branch: refs/heads/master Commit: 2d55cf0dcbdf2fd182e690209bc86e898f9e01d8 Parents: 2cbbd32 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Thu Mar 26 14:45:43 2015 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Fri Apr 3 08:48:03 2015 +0200

[02/10] flink git commit: [FLINK-671] Python API

http://git-wip-us.apache.org/repos/asf/flink/blob/d182daa1/flink-staging/flink-language-binding/pom.xml -- diff --git a/flink-staging/flink-language-binding/pom.xml b/flink-staging/flink-language-binding/pom.xml index

[03/10] flink git commit: [FLINK-671] Python API

http://git-wip-us.apache.org/repos/asf/flink/blob/d182daa1/flink-staging/flink-language-binding/flink-python/src/main/python/org/apache/flink/languagebinding/api/python/flink/plan/DataSet.py -- diff --git

[07/10] flink git commit: [FLINK-671] Python API

[FLINK-671] Python API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d182daa1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d182daa1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d182daa1 Branch:

[10/10] flink git commit: [Flink-671] Python API additions

[Flink-671] Python API additions Fixes several minor issues Requesting non-available data throws Exception Python process shutodwn more reliable Synchronization done via TCP Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[09/10] flink git commit: [FLINK-377] Generic Interface

[FLINK-377] Generic Interface Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af9248c3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/af9248c3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/af9248c3 Branch:

[04/10] flink git commit: [FLINK-671] Python API

http://git-wip-us.apache.org/repos/asf/flink/blob/d182daa1/flink-staging/flink-language-binding/flink-python/src/main/python/org/apache/flink/languagebinding/api/python/flink/connection/Iterator.py -- diff --git

flink git commit: [FLINK-1799][scala] Fix handling of generic arrays

/repos/asf/flink/tree/4672e95e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4672e95e Branch: refs/heads/master Commit: 4672e95ef158bb5e52b1d493465d62429bbdb29e Parents: 56cb793 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Thu Apr 9 14:05:08 2015 +0200 Committer: Aljoscha

flink git commit: [hotfix] Remove asm dependency from root pom

/asf/flink/tree/58de10ae Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/58de10ae Branch: refs/heads/master Commit: 58de10ae372e112670f9587ecd52aab6e1c7b6b4 Parents: 84790ef Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Apr 29 17:14:43 2015 +0200 Committer: Aljoscha Krettek

[1/2] flink git commit: [FLINK-1615] [java api] SimpleTweetInputFormat

Repository: flink Updated Branches: refs/heads/master 40be172e4 - 8e429ced2 http://git-wip-us.apache.org/repos/asf/flink/blob/8e429ced/flink-contrib/src/main/resources/HashTagTweetSample.json -- diff --git

[2/2] flink git commit: [FLINK-924] Add JarFileCreator tests for anonymous classes and Java 8 lambdas

: http://git-wip-us.apache.org/repos/asf/flink/diff/64607433 Branch: refs/heads/master Commit: 64607433d449214dbdee326c5a798fe36d1ed0ca Parents: c527a2b Author: mingliang qmlm...@gmail.com Authored: Tue Oct 28 14:52:56 2014 +0100 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Tue Apr

[1/2] flink git commit: [FLINK-924] Add automatic dependency retrieval for JarFileCreator

-us.apache.org/repos/asf/flink/tree/c527a2b8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c527a2b8 Branch: refs/heads/master Commit: c527a2b8f42aa0d57cdda4b0b5fb35dcba1a2538 Parents: de573cf Author: mingliang qmlm...@gmail.com Authored: Sun Jun 22 21:20:55 2014 +0200 Committer: Aljoscha

[1/2] flink git commit: [FLINK-1997][table] Add and != for un-equal in expressions

-us.apache.org/repos/asf/flink/tree/3b8f60e9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3b8f60e9 Branch: refs/heads/master Commit: 3b8f60e9b6f65485db280124e5368f111b558e27 Parents: 2939fba Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri May 8 14:55:38 2015 +0200 Committer

[2/2] flink git commit: [FLINK-1998][table] Fix equals expression

/84dcb7c2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/84dcb7c2 Branch: refs/heads/master Commit: 84dcb7c20f5d67dbb5a931ab56e68594e491034b Parents: 3b8f60e Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri May 8 15:10:50 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret

flink git commit: [FLINK-1990] Support upper case of `as` for expression

: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Fri May 15 19:39:16 2015 +0200 -- .../flink/api/table/parser/ExpressionParser.scala | 12 +++- .../flink/api/scala/table/test/ExpressionsITCase.scala | 12

flink git commit: [FLINK-1900] Fix Scala Table API Example in doc

/asf/flink/tree/8c5cd973 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8c5cd973 Branch: refs/heads/master Commit: 8c5cd97356ee978c1e9a5b73b90677cfd1eef164 Parents: 354922b Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri Apr 17 09:00:30 2015 +0200 Committer: Aljoscha

flink git commit: [FLINK-1710] [table] Switch compile backend to Janino

-us.apache.org/repos/asf/flink/commit/f81d9f02 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f81d9f02 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f81d9f02 Branch: refs/heads/master Commit: f81d9f02212b05ea7770dc08743c866878f1364c Parents: 92e0c77 Author: Aljoscha Krettek

flink git commit: [doc] Fix typos and formatting in Flink on Tez doc

/repos/asf/flink/tree/41ab4360 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/41ab4360 Branch: refs/heads/master Commit: 41ab43604199f31b6a4256cdf23c549481cca9e8 Parents: b566884 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Apr 8 15:21:46 2015 +0200 Committer: Aljoscha

flink git commit: [hotfix] Fix scaladoc in Table.scala Examples

/asf/flink/tree/e48e76f4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e48e76f4 Branch: refs/heads/master Commit: e48e76f4660e7728ae0252736398c27e72841238 Parents: 365cd40 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Wed Apr 8 17:20:29 2015 +0200 Committer: Aljoscha Krettek

[4/7] flink git commit: [FLINK-1977] Rework Stream Operators to always be push based

http://git-wip-us.apache.org/repos/asf/flink/blob/58865ff3/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java -- diff --git

[1/7] flink git commit: Disable Test in ComplexIntegrationTest

/flink/tree/f59d6a11 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f59d6a11 Branch: refs/heads/master Commit: f59d6a11881be3c6d2174a720a04ec9a55160cc8 Parents: a04f091 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Tue May 19 11:12:59 2015 +0200 Committer: Aljoscha Krettek

[2/7] flink git commit: [FLINK-2009] Force chaining for System Operators

/asf/flink/tree/a04f0912 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a04f0912 Branch: refs/heads/master Commit: a04f091217cedccb00bb21a4686350e7709adea9 Parents: 58865ff Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon May 18 15:12:50 2015 +0200 Committer: Aljoscha

[3/7] flink git commit: [FLINK-1977] Rework Stream Operators to always be push based

http://git-wip-us.apache.org/repos/asf/flink/blob/58865ff3/flink-staging/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/windowing/TopSpeedWindowingExample.java -- diff --git

flink git commit: [FLINK-2160] Change Streaming Source Interface to run(Context)/cancel()

-us.apache.org/repos/asf/flink/diff/235b02cb Branch: refs/heads/master Commit: 235b02cb56d24bb5db3c254fa34661ccc0e1a083 Parents: 4b9e340 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Thu Jun 4 11:29:17 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Fri Jun 5

flink git commit: [hotfix][doc] Fix typo in Scala Shell doc

/flink/tree/1ac0fb47 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1ac0fb47 Branch: refs/heads/master Commit: 1ac0fb47afca87f174622c2289e03ac09f0b0461 Parents: a363308 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Sat Jun 6 18:39:29 2015 +0200 Committer: Aljoscha Krettek

flink git commit: [FLINK-2000][table] Add SQL-style Aggregation Support

/repos/asf/flink/tree/7805db81 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7805db81 Branch: refs/heads/master Commit: 7805db813dd744f13776320d556e1cefa0351464 Parents: 804430b Author: Cheng Hao chha...@gmail.com Authored: Thu Jun 4 23:17:35 2015 +0800 Committer: Aljoscha Krettek

flink git commit: [FLINK-2054] Add object-reuse switch for streaming

-us.apache.org/repos/asf/flink/diff/26304c20 Branch: refs/heads/master Commit: 26304c20ab6aab33daba775736061102bd7a2409 Parents: 7805db8 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon Jun 8 11:32:27 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Mon Jun 8 16:00

flink git commit: Implemented TwitterSourceFilter and adapted TwitterSource

: refs/heads/master Commit: bf9cc81a79951ebac40b00a5d8f67128a86efe4e Parents: bc7f6d9 Author: yildirim yildi...@gronau.neofonie.priv Authored: Tue May 19 14:27:27 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Wed Jun 3 12:21:51 2015 +0200

[1/3] flink git commit: [FLINK-2098] Ensure checkpoints and element emission are in order

Repository: flink Updated Branches: refs/heads/master 39010dce4 - f4195ac02 http://git-wip-us.apache.org/repos/asf/flink/blob/6685b0ba/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java

flink git commit: [hotfix] Fix YARNSessionFIFOITCase

://git-wip-us.apache.org/repos/asf/flink/commit/2eb5cfeb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2eb5cfeb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2eb5cfeb Branch: refs/heads/master Commit: 2eb5cfeb2dad061aa8e84040bd648b5198d2d142 Parents: 97611c2 Author: Aljoscha

flink git commit: [hotfix] Fix YARNSessionFIFOITCase

: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Tue Jun 9 14:56:17 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Tue Jun 9 14:58:30 2015 +0200 -- .../main/java/org/apache/flink/yarn

flink git commit: [FLINK-2210] Table API support for aggregation on columns with null values

: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Tue Jun 16 18:38:48 2015 +0200 -- .../table/codegen/ExpressionCodeGenerator.scala | 19 +++ .../api/table/expressions/aggregations.scala| 2 +- .../api/table

[2/3] flink git commit: Some code cleanups on Scala Shell

Branch: refs/heads/master Commit: 6bb6de22fb6602058430d6d4eebf7cf36e404aca Parents: 717f881 Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Tue May 26 14:35:53 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Thu May 28 15:48:17 2015 +0200

[3/3] flink git commit: [FLINK-1907] Add Flink Scala Shell

nikolaas.steenber...@googlemail.com Authored: Tue May 12 21:54:20 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Thu May 28 15:48:17 2015 +0200 -- docs/scala_shell_quickstart.md | 72

[2/2] flink git commit: [FLINK-2074] Fix erroneous emission of Sliding Time PreReducer

: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri May 22 16:30:58 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Tue May 26 10:21:31 2015 +0200 -- .../windowbuffer/SlidingGroupedPreReducer.java

[3/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator

http://git-wip-us.apache.org/repos/asf/flink/blob/bac21bf5/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/transformations/SplitTransformation.java -- diff --git

[5/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator

http://git-wip-us.apache.org/repos/asf/flink/blob/bac21bf5/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/IterativeDataStream.java -- diff --git

[1/6] flink git commit: [FLINK-2398][api-breaking] Introduce StreamGraphGenerator

Repository: flink Updated Branches: refs/heads/master baaa3daca - bac21bf5d http://git-wip-us.apache.org/repos/asf/flink/blob/bac21bf5/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/partitioner/FieldsPartitionerTest.java

flink git commit: [FLINK-2231] Create Serializer and Comparator for Scala Enumerations.

Jul 24 20:57:04 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Wed Jul 29 14:24:56 2015 +0200 -- .../flink/api/scala/codegen/TypeAnalyzer.scala | 38 ++- .../api/scala/codegen

flink git commit: [hotfix] Fix warnings introduced by recent Watermark Commit

-us.apache.org/repos/asf/flink/tree/31c0c292 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/31c0c292 Branch: refs/heads/master Commit: 31c0c2925c63c2999aa831602f52601d33cd6b47 Parents: efca79c Author: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Fri Jul 24 11:29:12 2015 +0200 Committer

[4/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/StreamGroupedFoldTest.java -- diff --git

[6/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BlockingQueueBroker.java -- diff --git

[8/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

: Aljoscha Krettek aljoscha.kret...@gmail.com Authored: Mon Jun 22 12:26:44 2015 +0200 Committer: Aljoscha Krettek aljoscha.kret...@gmail.com Committed: Mon Jul 20 18:52:45 2015 +0200 -- .../wrappers/StormBoltCollector.java

[5/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java -- diff --git

[7/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamReduce.java -- diff --git

[2/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardPartitionerTest.java -- diff --git

[1/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

Repository: flink Updated Branches: refs/heads/master 2d191ab05 - a2eb6cc87 http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/timestamp/TimestampITCase.java

[3/8] flink git commit: [FLINK-1967] Introduce (Event)time in Streaming

http://git-wip-us.apache.org/repos/asf/flink/blob/a2eb6cc8/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/operators/windowing/WindowIntegrationTest.java -- diff --git

[2/2] flink git commit: [hotfix] Improve handling of Window Trigger results

-wip-us.apache.org/repos/asf/flink/tree/e6969377 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e6969377 Branch: refs/heads/master Commit: e696937788c0fcba78dcdf820a5ebb70f8086710 Parents: e18cdd0 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 11:31:13 2015

[1/2] flink git commit: [hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime

d04 Branch: refs/heads/master Commit: e18cdd0498003417c2fe6b0f446f6a943fbc98e3 Parents: c36977f Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 11:28:58 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Oct 23 15:4

[2/2] flink git commit: [hotfix] Add Window Parameter in Trigger.onEventTime/onProcessingTime

Parents: 15d3f10 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 11:28:58 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Oct 23 17:38:24 2015 +0200 -- .

[2/3] flink git commit: [hotfix] Fix broken copy in OperatorChain

: http://git-wip-us.apache.org/repos/asf/flink/diff/45ab0eb8 Branch: refs/heads/release-0.10 Commit: 45ab0eb871de90171bcf5395ca6d2568876a37a8 Parents: c257abf Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 14:38:16 2015 +0200 Committer: Aljoscha Krettek <aljo

[1/3] flink git commit: Add copy() to Tuple base class.

asf/flink/tree/c257abf7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c257abf7 Branch: refs/heads/release-0.10 Commit: c257abf75773b3643692261018b6794debff6001 Parents: 85b73e0 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 12:48:02 2015 +0200 Committer:

[2/3] flink git commit: [hotfix] Fix broken copy in OperatorChain

: http://git-wip-us.apache.org/repos/asf/flink/diff/256a88a1 Branch: refs/heads/master Commit: 256a88a186dd7fe2a958d4bbc826fee3b806efc6 Parents: d056f11 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 14:38:16 2015 +0200 Committer: Aljoscha Krettek <aljo

[1/3] flink git commit: [hotfix] Fix Mutable Object window aggregator/Disable Object Copy

asf/flink/diff/c36977f7 Branch: refs/heads/master Commit: c36977f7676a5e9c0a1a8f45815d9517e56d38ae Parents: 256a88a Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 13:08:35 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Oct 2

[3/3] flink git commit: Add copy() to Tuple base class.

Branch: refs/heads/master Commit: d056f11ddf42a944b113a4ad46874a5b4d237653 Parents: bbb75c5 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 12:48:02 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Oct 23 15:37:5

flink git commit: [hotfix] Fix processing time triggering on Window Operator

po Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3385fa3a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3385fa3a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3385fa3a Branch: refs/heads/master Commit: 3385fa3ab5584f74df93cb9597c0405d0be391f5 Parents: cd7ed8e Author:

flink git commit: [hotfix] Fix processing time triggering on Window Operator

f4 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Oct 23 11:13:37 2015 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Fri Oct 23 11:15:21 2015 +0200 -- .../runtim

flink git commit: [hotfix] Fix shaky EventTimeAllWindowCheckpointITCase

ttp://git-wip-us.apache.org/repos/asf/flink/commit/42a4df2d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42a4df2d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/42a4df2d Branch: refs/heads/master Commit: 42a4df2d475910a9092a5f7251d4897d00b4fba9 Parents: b198c33 Author: Aljos

flink git commit: [hotfix] Fix issue with spaces in Path in start-*-streaming.sh

wip-us.apache.org/repos/asf/flink/tree/6a838db1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6a838db1 Branch: refs/heads/master Commit: 6a838db13e3955d30a273fb843438de563ea87ec Parents: 6a8e90b Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Oct 27 13:48:34 2

flink git commit: [FLINK-3024] Fix TimestampExtractor.getCurrentWatermark() Behaviour

mit: 42bef80a857ff37a1b06429374bc8647fa5fac1a Parents: 7c4cde3 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Nov 17 11:40:22 2015 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Tue Nov 17 14:3

flink git commit: [FLINK-3024] Fix TimestampExtractor.getCurrentWatermark() Behaviour

mit: bdb306a1152aa9938bde2cc536db540eb2ca40d0 Parents: 14c24e7 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Nov 17 11:40:22 2015 +0100 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Tue Nov 17 11:4

flink git commit: [hotfix] Add list_deps.py tool

wip-us.apache.org/repos/asf/flink/commit/474153d4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/474153d4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/474153d4 Branch: refs/heads/master Commit: 474153d4b73503f341454ff46388b593a102d87f Parents: 044bd42 Author: Aljoscha Kret

flink git commit: [FLINK-2979] Fix RollingSink truncate for Hadoop 2.7

iff: http://git-wip-us.apache.org/repos/asf/flink/diff/7f312d1e Branch: refs/heads/release-0.10 Commit: 7f312d1e596c5a7c8ee437822acb780657a68bea Parents: 63d92c7 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Fri Nov 6 16:15:06 2015 +0100 Committer: Aljoscha Krettek <a

flink git commit: [hotfix,doc] Fix link to coding guidelines, again

org/repos/asf/flink/tree/ede80e22 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ede80e22 Branch: refs/heads/master Commit: ede80e2279fa012df4d737de4e48bffce0b489c4 Parents: 474153d Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Tue Nov 3 14:49:52 2015 +0100 Committer:

flink git commit: [hotfix] Add ResultTypeQueryable to Keys in Stream CoGroup/Join

wip-us.apache.org/repos/asf/flink/tree/5c2c112b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5c2c112b Branch: refs/heads/master Commit: 5c2c112b2b2d3a8f14d7cd82da940d11feb8e097 Parents: f2186a6 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Wed Oct 7 22:59:08 2

  1   2   3   4   5   6   7   8   9   10   >