Commits

History for

Commits on Oct 13, 2014

Enable forgotten JoinITCase (for POJOs) for Scala and Java API
rmetzger
committedOct 13, 2014

Commits on Oct 9, 2014

[scala] Add missing operator IT Cases
aljoscha
committedOct 9, 2014
Simplify Pojo/Tuple/CaseClass comparator extractKeys() method
aljoscha
committedOct 9, 2014

Commits on Oct 8, 2014

Really add POJO support and nested keys for Scala API

aljoscha
authored and
rmetzger
committedOct 8, 2014
Add Pojo support to Scala API
rmetzger
committedOct 8, 2014
[FLINK-1032] Rework support for POJO types in the Java API
rmetzger
committedOct 8, 2014

Commits on Oct 6, 2014

Integration of new BLOB service.

warneke
authored and
tillrohrmann
committedOct 6, 2014

Commits on Oct 3, 2014

[FLINK-1110] Adjust tests and fix various issues in the collection-based execution.
StephanEwen
committedOct 3, 2014
[FLINK-1110] Add createCollectionEnvironment for Scala

aljoscha
authored and
StephanEwen
committedOct 3, 2014
[FLINK-1110] Started implementing the JoinOperatorBase.

tillrohrmann
authored and
StephanEwen
committedOct 3, 2014
[FLINK-1110] Add Collection-Based execution for Reduce Operators

aljoscha
authored and
StephanEwen
committedOct 3, 2014

Commits on Oct 2, 2014

Move DeltaIteration Sanity Check to Base Operators
aljoscha
committedOct 2, 2014

Commits on Oct 1, 2014

Guava shading fixes for eclipse and IntelliJ
StephanEwen
committedOct 1, 2014
[scala] Simplify Operation Classes: No more Impl Classes
aljoscha
committedOct 1, 2014

Commits on Sep 30, 2014

- Allow dependencies to retain guava
StephanEwen
committedSep 30, 2014
[FLINK-1005] Extend TypeSerializer interface to handle non-mutable object deserialization more efficiently.
StephanEwen
committedSep 30, 2014

Commits on Sep 29, 2014

[FLINK-1120] Add Explicit Partition/Rebalance Operator for Scala API
aljoscha
committedSep 29, 2014
[FLINK-1123] Add first-n to Scala API
aljoscha
committedSep 29, 2014
Fix Bug in ScalaAggregate Operator and add ITCase
aljoscha
committedSep 29, 2014

Commits on Sep 24, 2014

Added parameter checks and tests for first-n operator.
fhueske
committedSep 24, 2014
Exclude DataSet.rebalance() and DataSet.partitionByHash() methods from ScalaAPICompletenessTest
fhueske
committedSep 24, 2014

Commits on Sep 23, 2014

Commits on Sep 22, 2014

[FLINK-1111] Move Basic and Array Type Information into "flink-core" Project
StephanEwen
committedSep 22, 2014
[scala] Add package documentation for package api.scala
aljoscha
committedSep 22, 2014
[scala] Add and* methods to AggregateDateSet
aljoscha
committedSep 22, 2014
Add ExecutionEnvironment to ScalaAPICompletessTest
aljoscha
committedSep 22, 2014
Rename ScalaTupleTypeInfo to CaseClassTypeInfo
aljoscha
committedSep 22, 2014
[scala] Add Scalastyle, use scalastyle-config.xml from Spark
aljoscha
committedSep 22, 2014
[scala] Reactivate DeltaIterationSanityCheckTest
aljoscha
committedSep 22, 2014
[scala] Fix Formatting in Examples and add ITCases
aljoscha
committedSep 22, 2014
Fix rename of java example package to examples
aljoscha
committedSep 22, 2014
Add Scala API completeness Test
aljoscha
committedSep 22, 2014
Add SemanticPropertiesTranslationTest for Scala API
aljoscha
committedSep 22, 2014