[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-10-08 Thread r-pogalz
Github user r-pogalz commented on a diff in the pull request: https://github.com/apache/flink/pull/1138#discussion_r41505034 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/base/OuterJoinOperatorBase.java --- @@ -0,0 +1,314 @@ +/* + * Licensed

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

2015-09-07 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/1052#issuecomment-138221929 The warnings fix commit is ready for review. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

2015-09-04 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/1052#issuecomment-137780075 Thanks for you comment @StephanEwen, good to know that. I tried to minimize the occurrences of warnings where possible by fixing or suppressing it for this issue

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

2015-08-29 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/1052#issuecomment-136056199 Hi @tillrohrmann, @fhueske and @chiwanpark, thanks for your reviews and comments. I went through the classes and changed the formatting. Moreover, I refactored

[GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F...

2015-08-26 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/1052#issuecomment-134898862 Hi @tillrohrmann, thanks for your review and comments. I will work through it soon. Regarding the ticket FLINK-2106, @fhueske suggested us to create multiple

[GitHub] flink pull request: [FLINK-2106] Runtime part

2015-08-24 Thread r-pogalz
GitHub user r-pogalz opened a pull request: https://github.com/apache/flink/pull/1052 [FLINK-2106] Runtime part This PR includes the implementation of 3 drivers (Left-, Right-, FullOuterJoinDriver) and adapts the DriverStrategy for the merge based outer joins (LEFT_, RIGHT_

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-08-04 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-127546250 Alright, I created a ticket ([FLINK-2479](https://issues.apache.org/jira/browse/FLINK-2479)) for adjustment of the other tests. Is there still anything left

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-08-03 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-127293419 Hello @fhueske, I see you noticed that we replaced all occurrences of `Record` by `Tuple2Integer, String` in the InnerJoin- and OuterJoinITCases. The issue

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-07-30 Thread r-pogalz
Github user r-pogalz commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-126517321 @fhueske, I ran through the classes and tried to catch all occurrences of `match` and replaced them by `join`. Hopefully I did not miss something :) Moreover, I

[GitHub] flink pull request: FLINK-2105: Implement Sort-Merge Outer Join al...

2015-07-13 Thread r-pogalz
GitHub user r-pogalz opened a pull request: https://github.com/apache/flink/pull/907 FLINK-2105: Implement Sort-Merge Outer Join algorithm This pull request relates to [FLINK-2105](https://issues.apache.org/jira/browse/FLINK-2105) and includes: * Extraction