Yeah. With the current standard operators, it is not necessary. However, For the new CustomOperator I am working on, it is needed. Streamlet classes are responsible for creating the operator objects and hook up the grouping. However CustomOperatorStreamlet will be shared by all user defined CustomOperators.
Another case is that in your proposal to change the streamlet style to be like: reduce(...) .windowed(...) .byKey() ... .build(); then the byKey() implementation will likely to need the grouping strategies to have their own classes. [ Full content available at: https://github.com/apache/incubator-heron/pull/3040 ] This message was relayed via gitbox.apache.org for [email protected]
