- 26 9月, 2014 2 次提交
-
-
由 Aljoscha Krettek 提交于
Checkstyle doesn't seem to support Java 8 yet.
-
由 twalthr 提交于
Checking for Java support Small changes and meaningful exception for unsupported compilers pom.xml modified to use JDT compiler Project structure refactored, examples added Documentation added Quickstart adapted
-
- 25 9月, 2014 18 次提交
-
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Aljoscha Krettek 提交于
Also update documentation accordingly.
-
由 Aljoscha Krettek 提交于
-
由 Ufuk Celebi 提交于
-
由 mbalassi 提交于
-
由 mbalassi 提交于
-
由 Gyula Fora 提交于
-
由 mbalassi 提交于
[FLINK-1103] [streaming] Updated WordCount example to become self-contained and removed old TestDataUtil
-
由 mbalassi 提交于
-
由 Gyula Fora 提交于
-
由 Gyula Fora 提交于
Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java Conflicts: flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/JobGraphBuilder.java flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedDataStream.java flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
-
由 szape 提交于
[streaming] added batchReduceGroup, windowReduceGroup functionality to ConnectedDataStream and GroupedConnectedDataStream
-
由 Gyula Fora 提交于
-
由 ghermann 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
Excluded DataSet.first(), UnsortedGrouping.first(), and SortedGrouping.first() methods from ScalaAPICompletenessTest.
-
- 24 9月, 2014 15 次提交
-
-
由 zentol 提交于
This closes #88
-
由 Fabian Hueske 提交于
- GroupReduceCombineDriver uses separate comparators for sorting and grouping. - Adding support for multiple comparators for a single input driver required some refactoring. This closes #109
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
-
由 Fabian Hueske 提交于
[FLINK-1060] Added methods to DataSet to explicitly hash-partition or rebalance the input of Map-based operators. This closes #108
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
Tasks are marked correctly as failed (not canceled), when the taskmanager kills then during shutdown or reset.
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
[FLINK-1115] Local file streams retry file creation on FileNotFoundException to increase resilience against spurious failures in tests
-
由 Stephan Ewen 提交于
[FLINK-1114] Move scala-style checks to scala projects, change paths to style conifg, to allow isolated building of individual projects.
-
- 23 9月, 2014 5 次提交
-
-
由 Till Rohrmann 提交于
Updated license notices in in java files to be written in block comments instead of javadoc comments.
-
由 Till Rohrmann 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-
由 Stephan Ewen 提交于
-