- 01 3月, 2016 5 次提交
-
-
由 Robert Metzger 提交于
This closes #1737
-
由 Aljoscha Krettek 提交于
This brings it more in line with *ProcessingTimeWindows and makes it clear what type of window assigner it is. The old name, i.e. SlidingTimeWindows and TumblingTimeWindows is still available but deprecated.
-
由 Aljoscha Krettek 提交于
This enforces that the user always has to specify keys for both inputs before .window() can be called.
-
由 Ufuk Celebi 提交于
This closes #1732.
-
由 Ufuk Celebi 提交于
This closes #1735.
-
- 29 2月, 2016 7 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Till Rohrmann 提交于
The current flink-gelly-examples artifact id wrongly used an underscore to separate examples from flink-gelly. This commit replaces the underscore with an hyphen. This closes #1731.
-
由 Robert Metzger 提交于
-
由 Ufuk Celebi 提交于
This closes #1716.
-
由 Ufuk Celebi 提交于
-
由 sahitya-pavurala 提交于
This closes #1700.
-
- 28 2月, 2016 1 次提交
-
-
由 Jark Wu 提交于
Closes #1730
-
- 27 2月, 2016 17 次提交
-
-
由 Aljoscha Krettek 提交于
This implicitly adds KeyedStream.transform() and also explicitly ConnectedStreams.transform(). This also removes the transform exclusions from the API completeness tests.
-
由 Aljoscha Krettek 提交于
This makes AllWindowedStream.fold() take constant space, just like the keyed WindowOperator. Also this adds a new test case in EventTimeAllWindowCheckpointingITCase to verify that the FoldingWindowBuffer works. This also renames the preexisting window buffers to ReducingWindowBuffer and ListWindowBuffer to make the naming scheme consistent.
-
由 Aljoscha Krettek 提交于
This closes #1723
-
由 Stephan Ewen 提交于
This closes #1727
-
由 Till Rohrmann 提交于
This closes #1725
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
-
由 Till Rohrmann 提交于
The new flink-gelly-examples module contains all Java and Scala Gelly examples. The module contains compile scope dependencies on flink-java, flink-scala and flink-clients so that the examples can be conveniently run from within the IDE.
-
由 Till Rohrmann 提交于
This closes #1719
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-3522] [storm compat] PrintSampleStream prints a proper message when involked without arguments
-
由 Stephan Ewen 提交于
This also includes some minor cleanups This closes #1689
-
由 Ufuk Celebi 提交于
Temporary work around to restore initial state on failure during recovery as required by a user. Will be superseded by FLINK-3397 with better handling of checkpoint and savepoint restoring. A failure during recovery resulted in restarting a job without its savepoint state. This temporary work around makes sure that if the savepoint coordinator ever restored a savepoint and there was no checkpoint after the savepoint, the savepoint state will be restored again. This closes #1720.
-
- 26 2月, 2016 10 次提交
-
-
由 vasia 提交于
This closes #1714
-
由 Stefano Baghino 提交于
* Explicitly state to stop the local environment This closes #1718
-
由 Robert Metzger 提交于
-
由 Stephan Ewen 提交于
This makes sure that for bounded data sets with watermarks, the final elements get properly reflected in window results.
-
由 zentol 提交于
This closes #1675
-
由 zentol 提交于
This closes #1695
-
由 Robert Metzger 提交于
This closes #1713
-
由 Greg Hogan 提交于
A second attempt at object swapping in reduce drivers. This closes #1626
-
由 Greg Hogan 提交于
Transitive dependency EvEmitter updated to 1.0.2 This closes #1661
-
由 Maximilian Michels 提交于
The change improves the display of SerializedListAccumulators in the web interface by displaying the number of elements contained in the accumulator instead of the hash code of the object. This closes #1717.
-