- 09 6月, 2015 5 次提交
-
-
由 Till Rohrmann 提交于
[ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme.
-
由 fobeligi 提交于
[FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation. This closes #798.
-
由 mjsax 提交于
This closes #796.
-
由 mbalassi 提交于
-
由 Gabor Gevay 提交于
Closes #806
-
- 08 6月, 2015 15 次提交
-
-
由 Maximilian Michels 提交于
-
由 Aljoscha Krettek 提交于
The switch was already there: enableObjectReuse() in ExecutionConfig. This was simply not considered by the streaming runtime. This change now draws a copy before forwarding an element to a chained operator when object reuse is disabled.
-
由 Cheng Hao 提交于
-
由 Maximilian Michels 提交于
- remove Maven dependencies - add docs to show how to register your own serializer with Kryo This closes #794.
-
由 Christian Wuerz 提交于
Closes #787
-
由 Robert Metzger 提交于
Closes #778
-
由 mbalassi 提交于
This is a temporal workaround for a bug in hbase. Closes #800
-
由 Sebastian Kruse 提交于
* register decompression algorithms with file extensions for extensibility * fit deflate decompression into this scheme * add support for GZIP files * test support for deflate and GZIP files with the CsvInputFormat * replace Apache Commons' Validate with Guava's Preconditions * add documentation on reading compressed files This closes #762.
-
由 twalthr 提交于
This closes #729.
-
由 Ufuk Celebi 提交于
-
由 Robert Metzger 提交于
This closes #788
-
由 Robert Metzger 提交于
This closes #774
-
由 Robert Metzger 提交于
This closes #784
-
由 Peter Schrott 提交于
[flink-core] Added the member currentSplit to FileInputFormat. This member contains the split that this parallel instance must consume. This closes #791
-
由 Robert Metzger 提交于
This closes #795
-
- 07 6月, 2015 2 次提交
-
-
由 Maximilian Michels 提交于
-
由 Aljoscha Krettek 提交于
-
- 06 6月, 2015 9 次提交
-
-
由 Gábor Hermann 提交于
Closes #771
-
由 Gábor Hermann 提交于
-
由 Gábor Hermann 提交于
-
由 Gábor Hermann 提交于
-
由 mbalassi 提交于
Closes #789
-
由 mbalassi 提交于
-
由 Stephan Ewen 提交于
-
由 Robert Metzger 提交于
This closes #781
-
由 Robert Metzger 提交于
This closes #786
-
- 05 6月, 2015 8 次提交
-
-
由 Fabian Hueske 提交于
This closes #793
-
由 Aljoscha Krettek 提交于
The context can be used to emit elements and retrieve the checkpointing lock object. In the future, the context can be extended to provide support for element emission with timestamps and dealing with the watermark system.
-
由 Stephan Ewen 提交于
[tests] Increase timeouts for process failure tests in order to compensate for volatile CI environments (Travis)
-
由 Stephan Ewen 提交于
-
由 Maximilian Michels 提交于
-
由 Robert Metzger 提交于
This closes #783
-
由 mjsax 提交于
- WebClient assembler class flag is '-c' (not 'assembler') - doc-building script is named 'build_docs.sh' (not '_build_docs.sh')
- 04 6月, 2015 1 次提交
-
-
由 Stephan Ewen 提交于
-