diff --git a/src/test/resources/blame/blameTestWithLocalRepo10.txt b/src/test/resources/blame/blameTestWithLocalRepo10.txt index 22239a1049b..10023d01e63 100644 --- a/src/test/resources/blame/blameTestWithLocalRepo10.txt +++ b/src/test/resources/blame/blameTestWithLocalRepo10.txt @@ -165,7 +165,7 @@ f1e80e4ec src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Michal 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 165) filters.add(filter); 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 166) } 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 167) else { -4cef3f91f src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Subbu Dantu 2017-04-11 04:40:33 +0000 168) throw new CheckstyleException( +a17065517 src/checkstyle/com/puppycrawl/tools/checkstyle/TreeWalker.java (Lars Kühne 2003-02-11 06:20:50 +0000 168) throw new CheckstyleException( 4cef3f91f src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Subbu Dantu 2017-04-11 04:40:33 +0000 169) "TreeWalker is not allowed as a parent of " + name 4cef3f91f src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Subbu Dantu 2017-04-11 04:40:33 +0000 170) + " Please review 'Parent Module' section for this Check in web" 4cef3f91f src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Subbu Dantu 2017-04-11 04:40:33 +0000 171) + " documentation if Check is standard."); @@ -190,7 +190,7 @@ f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 190) addMessages(messages); f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 191) } f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 192) else { -58327e1dd src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Pavel Bludov 2018-01-24 06:39:46 +0000 193) final SortedSet filteredMessages = +6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 193) final SortedSet filteredMessages = 58327e1dd src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Pavel Bludov 2018-01-24 06:39:46 +0000 194) getFilteredMessages(file.getPath(), contents, rootAST); 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 195) addMessages(filteredMessages); f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 196) } @@ -209,7 +209,7 @@ f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 209) String fileName, FileContents fileContents, DetailAST rootAST) { 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 210) final SortedSet result = new TreeSet<>(messages); 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 211) for (LocalizedMessage element : messages) { -f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 212) final TreeWalkerAuditEvent event = +6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 212) final TreeWalkerAuditEvent event = f99451271 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-08-23 15:11:26 +0000 213) new TreeWalkerAuditEvent(fileContents, fileName, element, rootAST); 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 214) for (TreeWalkerFilter filter : filters) { 6d9e8ece8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Timur 2017-07-24 20:38:15 +0000 215) if (!filter.accept(event)) { @@ -248,7 +248,7 @@ a2fded8ed src/checkstyle/com/puppycrawl/tools/checkstyle/TreeWalker.java (Lars K 39ce82b92 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (alexkravin 2015-02-08 21:46:27 +0000 248) else { be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 249) final String message = String.format(Locale.ROOT, "Token \"%s\" was " be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 250) + "not found in Acceptable tokens list in check %s", -be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 251) token, check.getClass().getName()); +085ce12db src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-08-25 23:00:09 +0000 251) token, check.getClass().getName()); 085ce12db src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-08-25 23:00:09 +0000 252) throw new CheckstyleException(message); 39ce82b92 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (alexkravin 2015-02-08 21:46:27 +0000 253) } 19257b2cd src/checkstyle/com/puppycrawl/tools/checkstyle/TreeWalker.java (Oliver Burn 2002-09-15 12:44:17 +0000 254) } @@ -286,8 +286,8 @@ b8ca6a585 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (alexkr a24df47ca src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Baratali Izmailov 2014-10-18 05:19:10 +0000 286) } cdf3e56ba src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ilja Dubinin 2015-08-27 12:17:01 +0000 287) else if (TokenUtils.isCommentType(token)) { be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 288) final String message = String.format(Locale.ROOT, "Check '%s' waits for comment type " -be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 289) + "token ('%s') and should override 'isCommentNodesRequired()' " -be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 290) + "method to return 'true'", check.getClass().getName(), token); +4d8d047f4 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Michal Kordas 2015-09-06 12:17:36 +0000 289) + "token ('%s') and should override 'isCommentNodesRequired()' " +ee518dfe8 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Michal Kordas 2015-04-13 21:43:00 +0000 290) + "method to return 'true'", check.getClass().getName(), token); 0bff657f6 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Roman Ivanov 2015-09-14 01:19:24 +0000 291) throw new CheckstyleException(message); a24df47ca src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Baratali Izmailov 2014-10-18 05:19:10 +0000 292) } a24df47ca src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Baratali Izmailov 2014-10-18 05:19:10 +0000 293) else { @@ -308,7 +308,7 @@ afd9a5c3e src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Andrei afd9a5c3e src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Andrei Selkin 2015-08-25 12:29:56 +0000 308) if (Arrays.binarySearch(defaultTokens, token) < 0) { be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 309) final String message = String.format(Locale.ROOT, "Token \"%s\" from required " be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 310) + "tokens was not found in default tokens list in check %s", -be3e035ce src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-10-13 23:37:10 +0000 311) token, check.getClass().getName()); +60ae95a62 src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Michal Kordas 2015-08-27 12:41:39 +0000 311) token, check.getClass().getName()); 085ce12db src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Ruslan Diachenko 2015-08-25 23:00:09 +0000 312) throw new CheckstyleException(message); afd9a5c3e src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Andrei Selkin 2015-08-25 12:29:56 +0000 313) } afd9a5c3e src/main/java/com/puppycrawl/tools/checkstyle/TreeWalker.java (Andrei Selkin 2015-08-25 12:29:56 +0000 314) } diff --git a/src/test/resources/blame/blameTestWithLocalRepo11.txt b/src/test/resources/blame/blameTestWithLocalRepo11.txt index 3a8a1f6ee8d..90c441ed9fb 100644 --- a/src/test/resources/blame/blameTestWithLocalRepo11.txt +++ b/src/test/resources/blame/blameTestWithLocalRepo11.txt @@ -192,7 +192,7 @@ fc40d1cb6 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Co fc40d1cb6 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-09-07 23:03:37 +0000 192) throw new IllegalArgumentException("The date must not be null"); fc40d1cb6 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-09-07 23:03:37 +0000 193) } 35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 194) return cal1.get(Calendar.ERA) == cal2.get(Calendar.ERA) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 195) cal1.get(Calendar.YEAR) == cal2.get(Calendar.YEAR) && +fc40d1cb6 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-09-07 23:03:37 +0000 195) cal1.get(Calendar.YEAR) == cal2.get(Calendar.YEAR) && 35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 196) cal1.get(Calendar.DAY_OF_YEAR) == cal2.get(Calendar.DAY_OF_YEAR); fc40d1cb6 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-09-07 23:03:37 +0000 197) } 198) @@ -251,12 +251,12 @@ b0053ca69 src/java/org/apache/commons/lang/time/DateUtils.java (Gary D. Gr 61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 251) throw new IllegalArgumentException("The date must not be null"); 61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 252) } 35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 253) return cal1.get(Calendar.MILLISECOND) == cal2.get(Calendar.MILLISECOND) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 254) cal1.get(Calendar.SECOND) == cal2.get(Calendar.SECOND) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 255) cal1.get(Calendar.MINUTE) == cal2.get(Calendar.MINUTE) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 256) cal1.get(Calendar.HOUR_OF_DAY) == cal2.get(Calendar.HOUR_OF_DAY) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 257) cal1.get(Calendar.DAY_OF_YEAR) == cal2.get(Calendar.DAY_OF_YEAR) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 258) cal1.get(Calendar.YEAR) == cal2.get(Calendar.YEAR) && -35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 259) cal1.get(Calendar.ERA) == cal2.get(Calendar.ERA) && +61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 254) cal1.get(Calendar.SECOND) == cal2.get(Calendar.SECOND) && +61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 255) cal1.get(Calendar.MINUTE) == cal2.get(Calendar.MINUTE) && +3e5d5dc9c src/main/java/org/apache/commons/lang3/time/DateUtils.java (Niall Pemberton 2011-02-02 21:55:15 +0000 256) cal1.get(Calendar.HOUR_OF_DAY) == cal2.get(Calendar.HOUR_OF_DAY) && +61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 257) cal1.get(Calendar.DAY_OF_YEAR) == cal2.get(Calendar.DAY_OF_YEAR) && +61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 258) cal1.get(Calendar.YEAR) == cal2.get(Calendar.YEAR) && +61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 259) cal1.get(Calendar.ERA) == cal2.get(Calendar.ERA) && 35f1cc002 src/main/java/org/apache/commons/lang3/time/DateUtils.java (Benedikt Ritter 2015-04-06 19:48:22 +0000 260) cal1.getClass() == cal2.getClass(); 61cccd3e0 src/java/org/apache/commons/lang/time/DateUtils.java (Stephen Colebourne 2004-10-16 17:08:42 +0000 261) } 262) diff --git a/src/test/resources/blame/blameTestWithLocalRepo9.txt b/src/test/resources/blame/blameTestWithLocalRepo9.txt index d0052a00923..69456b8cc03 100644 --- a/src/test/resources/blame/blameTestWithLocalRepo9.txt +++ b/src/test/resources/blame/blameTestWithLocalRepo9.txt @@ -337,7 +337,7 @@ cad85103e flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/a 337) 9e6e0aeca flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-10-05 14:36:35 +0000 338) private KeyedStream keyBy(Keys keys) { 2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 339) return new KeyedStream<>(this, clean(KeySelectorUtil.getSelectorForKeys(keys, -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 340) getType(), getExecutionConfig()))); +cad85103e flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Paris Carbone 2015-06-25 17:20:00 +0000 340) getType(), getExecutionConfig()))); cad85103e flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Paris Carbone 2015-06-25 17:20:00 +0000 341) } 342) 97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 343) /** @@ -388,17 +388,17 @@ bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/a 97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 388) */ bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 389) public DataStream partitionCustom(Partitioner partitioner, KeySelector keySelector) { 2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 390) return setConnectionType(new CustomPartitionerWrapper<>(clean(partitioner), -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 391) clean(keySelector))); +86080bb97 flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-10-11 10:12:41 +0000 391) clean(keySelector))); 97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 392) } 393) 97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 394) // private helper method for custom partitioning bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 395) private DataStream partitionCustom(Partitioner partitioner, Keys keys) { bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 396) KeySelector keySelector = KeySelectorUtil.getSelectorForOneKey(keys, partitioner, getType(), getExecutionConfig()); 397) -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 398) return setConnectionType( +97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 398) return setConnectionType( 2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 399) new CustomPartitionerWrapper<>( -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 400) clean(partitioner), -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 401) clean(keySelector))); +97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 400) clean(partitioner), +97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 401) clean(keySelector))); 97d10070c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gábor Hermann 2015-07-11 12:00:56 +0000 402) } 403) f60f28678 flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/DataStream.java (jfeher 2014-08-18 13:57:06 +0000 404) /** @@ -606,7 +606,7 @@ d56d48f1a flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/ap 3e83eb4fc flink-addons/flink-streaming/stratosphere-streaming-core/src/main/java/eu/stratosphere/streaming/api/DataStream.java (gyfora 2014-08-18 13:57:12 +0000 606) */ a922473c0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2016-02-29 20:37:19 +0000 607) public SingleOutputStreamOperator flatMap(FlatMapFunction flatMapper) { 608) -1cf49e90c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gyula Fora 2015-04-05 08:51:20 +0000 609) TypeInformation outType = TypeExtractor.getFlatMapReturnTypes(clean(flatMapper), +34353f665 flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gyula Fora 2015-01-02 17:34:38 +0000 609) TypeInformation outType = TypeExtractor.getFlatMapReturnTypes(clean(flatMapper), 1cf49e90c flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Gyula Fora 2015-04-05 08:51:20 +0000 610) getType(), Utils.getCallLocationName(), true); 611) 2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 612) return transform("Flat Map", outType, new StreamFlatMap<>(clean(flatMapper))); @@ -630,15 +630,15 @@ a922473c0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/data 0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 630) @PublicEvolving 0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 631) public SingleOutputStreamOperator process(ProcessFunction processFunction) { 632) -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 633) TypeInformation outType = TypeExtractor.getUnaryOperatorReturnType( -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 634) processFunction, -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 635) ProcessFunction.class, -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 636) 0, -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 637) 1, -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 638) TypeExtractor.NO_INDEX, -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 639) getType(), -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 640) Utils.getCallLocationName(), -ddba1b69f flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Timo Walther 2018-07-20 06:06:07 +0000 641) true); +0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 633) TypeInformation outType = TypeExtractor.getUnaryOperatorReturnType( +0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 634) processFunction, +0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 635) ProcessFunction.class, +bcaf816dc flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Dawid Wysakowicz 2017-06-08 08:42:41 +0000 636) 0, +bcaf816dc flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Dawid Wysakowicz 2017-06-08 08:42:41 +0000 637) 1, +afb0b630c flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Dawid Wysakowicz 2017-06-17 10:00:49 +0000 638) TypeExtractor.NO_INDEX, +0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 639) getType(), +0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 640) Utils.getCallLocationName(), +0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 641) true); 642) 0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 643) return process(processFunction, outType); 0228676d6 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2017-03-06 11:26:16 +0000 644) } @@ -1077,9 +1077,9 @@ c08bcf1e0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/data c08bcf1e0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Till Rohrmann 2015-12-21 15:59:03 +0000 1077) "The writeAsCsv() method can only be used on data streams of tuples."); 1078) 2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1079) CsvOutputFormat of = new CsvOutputFormat<>( -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1080) new Path(path), -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1081) rowDelimiter, -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1082) fieldDelimiter); +c08bcf1e0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Till Rohrmann 2015-12-21 15:59:03 +0000 1080) new Path(path), +c08bcf1e0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Till Rohrmann 2015-12-21 15:59:03 +0000 1081) rowDelimiter, +c08bcf1e0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Till Rohrmann 2015-12-21 15:59:03 +0000 1082) fieldDelimiter); 1083) dc0d81bb8 flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (szape 2015-01-21 15:05:25 +0000 1084) if (writeMode != null) { dc0d81bb8 flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (szape 2015-01-21 15:05:25 +0000 1085) of.setWriteMode(writeMode); @@ -1144,13 +1144,13 @@ bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/a bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1144) transformation.getOutputType(); 1145) 2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1146) OneInputTransformation resultTransform = new OneInputTransformation<>( -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1147) this.transformation, -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1148) operatorName, -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1149) operator, -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1150) outTypeInfo, -2714aaf3d flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Robert Metzger 2016-02-16 14:52:53 +0000 1151) environment.getParallelism()); +bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1147) this.transformation, +bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1148) operatorName, +bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1149) operator, +bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1150) outTypeInfo, +bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1151) environment.getParallelism()); 1152) -a922473c0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2016-02-29 20:37:19 +0000 1153) @SuppressWarnings({ "unchecked", "rawtypes" }) +d56d48f1a flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/DataStream.java (gyfora 2014-08-18 14:23:16 +0000 1153) @SuppressWarnings({ "unchecked", "rawtypes" }) a922473c0 flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2016-02-29 20:37:19 +0000 1154) SingleOutputStreamOperator returnStream = new SingleOutputStreamOperator(environment, resultTransform); 1155) bac21bf5d flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java (Aljoscha Krettek 2015-08-19 15:53:04 +0000 1156) getExecutionEnvironment().addOperator(resultTransform);