Github user arunmahadevan commented on a diff in the pull request:
https://github.com/apache/storm/pull/1663#discussion_r81950911
--- Diff: storm-core/src/jvm/org/apache/storm/trident/Stream.java ---
@@ -440,6 +459,27 @@ public Stream flatMap(FlatMapFunction function) {
}
/**
+ * Returns a stream consisting of the results of replacing each value
of this stream with the contents
+ * produced by applying the provided mapping function to each value.
This has the effect of applying
+ * a one-to-many transformation to the values of the stream, and then
flattening the resulting elements into a new stream.
+ * This method replaces old output fields with new output fields,
achieving T -> V conversion.
+ *
+ * @param function a mapping function to be applied to each value in
this stream which produces new values.
+ * @param outputFields new output fields
+ * @return the new stream
+ */
+ public Stream flatMap(FlatMapFunction function, Fields outputFields) {
+ projectionValidation(getOutputFields());
--- End diff --
Shouldnt this be outputFields?
---
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.
---
