Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105731937
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala
---
@@ -199,10 +200,21 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105639200
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user tonycox commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105600606
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104730718
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala
---
@@ -124,8 +127,26 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105014912
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -125,11 +126,25 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104708548
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetAggregate.scala
---
@@ -125,11 +126,25 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105029771
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105030757
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104685724
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCorrelate.scala
---
@@ -46,6 +46,7 @@ trait CommonCorrelate {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105029829
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104723484
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCorrelate.scala
---
@@ -97,18 +103,41 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104706099
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105030435
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105023568
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala
---
@@ -124,8 +127,26 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104729449
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r105032956
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104730046
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104727584
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala
---
@@ -199,10 +200,21 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104727744
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala
---
@@ -199,10 +200,21 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104730153
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r104730024
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,143 @@
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r95975700
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/forwarding/FieldForwardingUtils.scala
---
@@ -0,0 +1,115 @@
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3040#discussion_r95975427
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetCalc.scala
---
@@ -129,8 +131,35 @@ class
GitHub user NickolayVasilishin opened a pull request:
https://github.com/apache/flink/pull/3040
[FLINK-3850] Add forward field annotations to DataSet
Add forward field annotations to DataSet operators generated by the Table
API
- Added field forwarding at most of
24 matches
Mail list logo
