Commits

Commits on Apr 29, 2015

[FLINK-1948] [streaming] Manual task slot sharing settings added for stream operators

gyfora
authored and
mbalassi
committedApr 29, 2015

Commits on Apr 26, 2015

[streaming] Timestamp comparison bugfix
gyfora
committedApr 26, 2015

Commits on Apr 22, 2015

[streaming] FullStream window helper added + partitioner bugfix
gyfora
committedApr 22, 2015
[FLINK-1909] [streaming] Type handling refactor for sources + scala api
gyfora
committedApr 22, 2015

Commits on Apr 20, 2015

[streaming] Parallel time reduce logic refactor to force prereducers
gyfora
committedApr 20, 2015

Commits on Apr 15, 2015

[streaming] Major internal renaming and restructure
gyfora
committedApr 15, 2015
[FLINK-1876] [streaming] StreamGraph refactor
gyfora
committedApr 15, 2015

Commits on Apr 14, 2015

[FLINK-1866] [streaming] StreamConfig key bugfix

gyfora
authored and
mbalassi
committedApr 14, 2015

Commits on Apr 10, 2015

[streaming] Removed unnecessary BatchIterator class
gyfora
committedApr 10, 2015
[FLINK-1838] [doc] Streaming programming guide update
gyfora
committedApr 10, 2015

Commits on Apr 8, 2015

Commits on Apr 5, 2015

[FLINK-1824] [streaming] Support added for missing types in DataStream api

gyfora
authored and
mbalassi
committedApr 5, 2015

Commits on Apr 3, 2015

[FLINK-1803] [streaming] returns(..) method added to Stream operators

gyfora
authored and
mbalassi
committedApr 3, 2015

Commits on Apr 1, 2015

[streaming] Streaming program cancellation bugfix
gyfora
committedApr 1, 2015

Commits on Mar 26, 2015

[FLINK-1775] BarrierBuffer fix to avoid end of stream deadlock
gyfora
committedMar 26, 2015
[FLINK-1773] [streaming] Introduced CentralActiveTrigger with GroupedActiveDiscretizer
gyfora
committedMar 26, 2015

Commits on Mar 22, 2015

[FLINK-1763] [streaming] Remove cancel from SinkFunction

gyfora
authored and
mbalassi
committedMar 22, 2015

Commits on Mar 20, 2015

Commits on Mar 19, 2015

[FLINK-1706] Resource cleanup added streaming readers with BarrierBuffers
gyfora
committedMar 19, 2015
[FLINK-1706] Spilling BarrierBuffer added + basic tests
gyfora
committedMar 19, 2015

Commits on Mar 15, 2015

[FLINK-1450] Several minor stream fold fixes
gyfora
committedMar 15, 2015

Commits on Mar 11, 2015

[FLINK-1619] [FLINK-1620] Grouped sliding prereducers added for Time and Count
gyfora
committedMar 11, 2015

Commits on Mar 10, 2015

[FLINK-1643] [streaming] Auto detection of tumbling policies added + WindowedDataStream refactor
gyfora
committedMar 10, 2015
[FLINK-1619] [FLINK-1620] Basic sliding prereducers added for Time and Count
gyfora
committedMar 10, 2015
[FLINK-1657] [streaming] Count window parallel discretization
gyfora
committedMar 10, 2015
[FLINK-1638] [streaming] RegisterState removed from datastream + CoRecordReader barrier test added

gyfora
authored and
StephanEwen
committedMar 10, 2015
[FLINK-1638] [streaming] Barrier sync added to CoRecordReader, barrier tests

gyfora
authored and
StephanEwen
committedMar 10, 2015
[FLINK-1638] [streaming] Seperated AbstractRecordReader for streaming and batch

gyfora
authored and
StephanEwen
committedMar 10, 2015
[FLINK-1638] [streaming] State interface cleanup

gyfora
authored and
StephanEwen
committedMar 10, 2015
[FLINK-1638] [streaming] Vertex level fault tolerance and state monitor

gyfora
authored and
StephanEwen
committedMar 10, 2015