Commits

History for

Commits on Mar 25, 2015

[Flink-1780] Rename FlatCombineFunction to GroupCombineFunction

smarthi
authored and
mxm
committedMar 25, 2015

Commits on Mar 23, 2015

[FLINK-1679] use a consistent name for parallelism
mxm
committedMar 23, 2015
[FLINK-1679] deprecate API methods to set the parallelism
mxm
committedMar 23, 2015

Commits on Mar 20, 2015

[FLINK-1760] [maven] Added Scala version profiles to support building with Scala 2.11

aalexandrov
authored and
StephanEwen
committedMar 20, 2015
[optimizer] Rename optimizer project to "flink-optimizer" (previously flink-compiler)
StephanEwen
committedMar 20, 2015

Commits on Mar 19, 2015

[FLINK-1720] Integrate ScalaDoc into JavaDoc

aljoscha
authored and
StephanEwen
committedMar 19, 2015

Commits on Mar 18, 2015

[FLINK-1622][java-api][scala-api] add a GroupCombine operator
mxm
committedMar 18, 2015

Commits on Mar 11, 2015

[FLINK-1605] Bundle all hadoop dependencies and shade guava away
rmetzger
committedMar 11, 2015

Commits on Mar 4, 2015

[scala-api] Corrects type cast in Scala API's DataSet.collect method and adds test cases for that
tillrohrmann
committedMar 4, 2015

Commits on Mar 2, 2015

Commits on Feb 27, 2015

[java-api][scala-api] convenience methods count/collect to transfer a DataSet to the client
mxm
committedFeb 27, 2015

Commits on Feb 23, 2015

[FLINK-947] Add a declarative Expression API
aljoscha
committedFeb 23, 2015
Add methods to CompositeType for querying field types and names
aljoscha
committedFeb 23, 2015

Commits on Feb 20, 2015

[FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs.
fhueske
committedFeb 20, 2015

Commits on Feb 18, 2015

[FLINK-1417] Automatically register types with Kryo
rmetzger
committedFeb 18, 2015

Commits on Feb 10, 2015

[FLINK-1369] [types] Add support for Subclasses, Interfaces, Abstract Classes.
aljoscha
committedFeb 10, 2015

Commits on Feb 9, 2015

[FLINK-1396][FLINK-1303] Hadoop Input/Output directly in API
aljoscha
committedFeb 9, 2015
[FLINK-1463] Fix stateful/stateless Serializers and Comparators
aljoscha
committedFeb 9, 2015

Commits on Feb 5, 2015

[FLINK-1415] [runtime] Akka cleanups
tillrohrmann
committedFeb 5, 2015
[scala api] Minor code cleanup for compiler warnings
StephanEwen
committedFeb 5, 2015
[FLINK-1318] [api-breaking] Simplified quoted string parsing, made it optional, and use a configurable quote character
fhueske
committedFeb 5, 2015

Commits on Feb 3, 2015

[FLINK-1165] [java-api] Rename "createCollectionEnvironment" to not break existing APIs.
StephanEwen
committedFeb 3, 2015
[FLINK-1165] [java-api] Add createCollectionsEnvironment to Java API

Ajay Bhat
authored and
StephanEwen
committedFeb 3, 2015

Commits on Jan 29, 2015

Remove semicolon in Scala files. Fix java doc alignment in AggregatorsITCase.java
hsaputra
committedJan 29, 2015

Commits on Jan 28, 2015

[FLINK-1328] [api-breaking][java-api][scala-api][optimizer] Reworked semantic annotations for functions.
fhueske
committedJan 28, 2015

Commits on Jan 26, 2015

[FLINK-1168] Add support for multi-char field delimiters in CSVInputFormats.
fhueske
committedJan 26, 2015

Commits on Jan 23, 2015

Commits on Jan 19, 2015

FLINK-1420 Small cleanup on code after branch for 0.8 release
hsaputra
committedJan 19, 2015
[FLINK-1395] Add tests for custom serializers with JodaTime.

aljoscha
authored and
StephanEwen
committedJan 19, 2015

Commits on Jan 18, 2015

[FLINK-1399] Fix kryo registration of types and make sure that tags are assigned for registered types.
StephanEwen
committedJan 18, 2015
[FLINK-1399] Add support for registering Serializers with Kryo

aljoscha
authored and
StephanEwen
committedJan 18, 2015
Minor dependencies cleanup:
StephanEwen
committedJan 18, 2015

Commits on Jan 15, 2015

[FLINK-1112] Additional checks for KeySelector group sorting and minor fixes
fhueske
committedJan 15, 2015