Commits

History for

Commits on Sep 22, 2014

Add SemanticPropertiesTranslationTest for Scala API
aljoscha
committedSep 22, 2014
Move RichFunctions to api.common package
aljoscha
committedSep 22, 2014
Move the Iteration "Operators" to the operators package
aljoscha
committedSep 22, 2014

Commits on Sep 20, 2014

JobManager checks for empty job graphs
StephanEwen
committedSep 20, 2014
Fix Java6 errors in AbstractID, pull JobManager changes into YARN app master
StephanEwen
committedSep 20, 2014
Port streaming package to new JobGraph API and adjust all runtime-level tests
StephanEwen
committedSep 20, 2014
Refactor job graph construction to incremental attachment based
StephanEwen
committedSep 20, 2014
[streaming] Minor bug fixes in Connectors, StreamCollector & docs
mbalassi
committedSep 20, 2014
[streaming] GroupedBatchReduce modified to batch by key, updated WindowReduce + Batch/Window reduce refactor

gyfora
authored and
mbalassi
committedSep 20, 2014
[streaming] Added checked exception to execution

ghermann
authored and
mbalassi
committedSep 20, 2014
[streaming] Added counter aggregation

ghermann
authored and
mbalassi
committedSep 20, 2014
[streaming] Added CoBatchGroupReduceInvokable, CoWindowGroupReduceInvokable and grouped variants

szape
authored and
mbalassi
committedSep 20, 2014
[streaming] Updated logging to utilize SLF4J

ghermann
authored and
mbalassi
committedSep 20, 2014
[streaming] window and batch operator added to DataStream + Documentation updated accordingly

gyfora
authored and
mbalassi
committedSep 20, 2014
[streaming] Invokables and tests added for fast batch/window reduce operations and aggregations

gyfora
authored and
mbalassi
committedSep 20, 2014
[streaming] DataStream type refactor for easier future extensions

gyfora
authored and
mbalassi
committedSep 20, 2014
[FLINK-1080] [streaming] Streaming aggregation update and refactor

gyfora
authored and
mbalassi
committedSep 20, 2014
[streaming] Added TypeInfo to DataStream
mbalassi
committedSep 20, 2014
[FLINK-1080] [streaming] Streaming aggregation added

eszesd
authored and
mbalassi
committedSep 20, 2014
[streaming] Updated directed emit to not use output names when all outputs are selected

ghermann
authored and
mbalassi
committedSep 20, 2014
[streaming] Reduce operator added to ConnectedDataStream + test

gyfora
authored and
mbalassi
committedSep 20, 2014
[streaming] Fixed SlidingWindowStateIterator

ghermann
authored and
mbalassi
committedSep 20, 2014

Commits on Sep 17, 2014

Remove naive verification of tuple size

physikerwelt
authored and
rmetzger
committedSep 17, 2014
[FLINK-1097] Fixed multiple slf4j bindings when using Hadoop2
tillrohrmann
committedSep 17, 2014

Commits on Sep 5, 2014

[FLINK-1086] Replace JCL with SLF4J and Log4j with LOGBack

tillrohrmann
authored and
uce
committedSep 5, 2014

Commits on Aug 29, 2014

[streaming] Added customizable timestamps to window operations

ghermann
authored and
StephanEwen
committedAug 29, 2014
[streaming] Added exceptions for wrong usage of StreamExecutionEnvironment

ghermann
authored and
StephanEwen
committedAug 29, 2014
[streaming] GroupReduceInvokable update

szape
authored and
StephanEwen
committedAug 29, 2014
[streaming] StreamInvokable refactor and javadoc update + StreamRecordSerializer update

gyfora
authored and
StephanEwen
committedAug 29, 2014
[FLINK-1065] [streaming] Explicitly adding commons-math dependency

mbalassi
authored and
StephanEwen
committedAug 29, 2014
[streaming] Removed assembly execution on maven package for connectors

mbalassi
authored and
StephanEwen
committedAug 29, 2014
[streaming] Tests added for Reduce, GroupReduce and BatchGroupReduce invokables

gyfora
authored and
StephanEwen
committedAug 29, 2014
[streaming] Added MockCoInvokable, replaced environments with it in CoFunction tests

ghermann
authored and
StephanEwen
committedAug 29, 2014
[streaming] Mutable and Immutable invoke in CoInvokable

jfeher
authored and
StephanEwen
committedAug 29, 2014
[streaming] reduce operator added to DataStream and ConnectedDataStream + grouped batch and windowReduce operators reworked

gyfora
authored and
StephanEwen
committedAug 29, 2014