- 26 9月, 2014 5 次提交
-
-
由 Henry Saputra 提交于
Remove unnecessary type check and cast for FileInputSPlit. Update LOG.debug to user SLF4J parameterized logging or protected by LOG.isDebugEnabled to save toString and String concat. Remove unnecessary semicolons. This closes #127
-
由 Aljoscha Krettek 提交于
-
由 Aljoscha Krettek 提交于
This closes #113
-
由 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 2 次提交
-
-
由 Till Rohrmann 提交于
Updated license notices in in java files to be written in block comments instead of javadoc comments.
-
由 Till Rohrmann 提交于
-