Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1848#discussion_r59176476
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java
---
@@ -98,6 +101,14 @@ public PartitionOperator(DataSet<T> input, Keys<T>
pKeys, Partitioner<?> customP
this.customPartitioner = customPartitioner;
this.distribution = distribution;
}
+
+ public PartitionOperator<T> withOrders(Order... orders) {
--- End diff --
The output of `ek.getOriginalKeyFieldTypes` should be:
`TypeInformation[] {TypeInformation<Pojo1>, TypeInformation<Integer>}`.
So the composite type `Pojo1` should not be flattened into its components,
i.e., `(String, String)`. This is important, because a user would only specify
two orders (one for each key expression) and the first one needs to applied to
all flat keys of `Pojo1`.
---
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 project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
