Commits

Commits on Nov 29, 2015

[FLINK-3075] Change Either creation method names and expose Right/Left classes
gyfora
committedNov 29, 2015

Commits on Nov 25, 2015

[FLINK-3072] [streaming] Ensure Derby server starts before running any tests
gyfora
committedNov 25, 2015

Commits on Nov 24, 2015

Commits on Oct 6, 2015

[FLINK-2822] [streaming] Remove scala.Serializable imports

gyfora
authored and
mbalassi
committedOct 6, 2015

Commits on Oct 4, 2015

[FLINK-2802] [streaming] Remove cyclic watermark dependencies for iterations
gyfora
committedOct 4, 2015

Commits on Sep 21, 2015

[FLINK-2713] [streaming] Set state restore to lazy to avoid StateCheckpointer issues and reduce checkpoint overhead
gyfora
committedSep 21, 2015

Commits on Sep 18, 2015

[FLINK-2707] [streaming] Set StateCheckpointer before default state value
gyfora
committedSep 18, 2015

Commits on Sep 14, 2015

[FLINK-2664] [streaming] Allow partitioned state removal
gyfora
committedSep 14, 2015

Commits on Aug 2, 2015

[FLINK-2436] [streaming] Make ByteStreamStateHandles more robust
gyfora
committedAug 2, 2015

Commits on Jul 30, 2015

[FLINK-2324] [streaming] Added test for different StateHandle wrappers
gyfora
committedJul 30, 2015
[FLINK-2324] [streaming] ITCase added for partitioned states
gyfora
committedJul 30, 2015
[FLINK-2324] [streaming] Partitioned state checkpointing rework + test update
gyfora
committedJul 30, 2015

Commits on Jul 29, 2015

[FLINK-2419] Add test for sinks after keyBy and groupBy
gyfora
committedJul 29, 2015

Commits on Jul 28, 2015

Commits on Jul 24, 2015

[streaming] Copy default state values for partitioned states
gyfora
committedJul 24, 2015

Commits on Jul 11, 2015

[FLINK-2335] [streaming] Lazy iteration construction in StreamGraph
gyfora
committedJul 11, 2015

Commits on Jul 7, 2015

[FLINK-2323] [api-breaking] Rename OperatorState interface methods to value() and update(..)
gyfora
committedJul 7, 2015

Commits on Jun 30, 2015

[FLINK-2294] [streaming] Fix partitioned state next-input setting for copying chained collectors
gyfora
committedJun 30, 2015

Commits on Jun 27, 2015

[streaming] Created scala GroupedDataStream
gyfora
committedJun 27, 2015

Commits on Jun 26, 2015

[FLINK-2261] [streaming] Remove reduce/fold/aggregations from DataStream
gyfora
committedJun 26, 2015
[FLINK-2279] [streaming] Add Connected Iteration
gyfora
committedJun 26, 2015

Commits on Jun 25, 2015