- 11 6月, 2015 3 次提交
-
-
由 Maximilian Michels 提交于
- we already decided to host them on the website - not really useful and they need maintenance - having the snapshot quickstart in the source is against Apache rules This closes #822.
-
由 Fabian Hueske 提交于
This closes #821
-
由 Theodore Vasiloudis 提交于
This closes #792.
-
- 10 6月, 2015 9 次提交
-
-
由 mbalassi 提交于
Closes #816
-
由 Aljoscha Krettek 提交于
The closure cleaner still cannot be disabled for the Timestamp extractor in Time and for the delta function in Delta (windowing helpers). Closes #813
-
由 Gyula Fora 提交于
-
由 Fabian Hueske 提交于
This closes #817
-
由 Aljoscha Krettek 提交于
-
由 Gabor Gevay 提交于
- The description of the input format for the graph examples showed an example input as having a newline at the end of the last line, but CsvInputFormat doesn't allow that (it says "Row too short" for the empty line). - Fixed a link to local_execution.html in a javadoc. - ConcatenatedExtract had a typo in its name. - The creation of the jar for the SessionWindowing example was missing from the pom. Closes #809
-
由 Till Rohrmann 提交于
[FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface This closes #814.
-
由 Gyula Fora 提交于
Closes #810
-
由 Aljoscha Krettek 提交于
Closes #804
-
- 09 6月, 2015 6 次提交
-
-
由 Aljoscha Krettek 提交于
When comparing the hostname, it was comparing capitalised vs. all-lowercase hostname from the yarn config.
-
由 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 5 次提交
-
-
由 Gábor Hermann 提交于
Closes #771
-
由 Gábor Hermann 提交于
-
由 Gábor Hermann 提交于
-
由 Gábor Hermann 提交于
-
由 mbalassi 提交于
Closes #789
-