• A
    Perform TypeExtraction outside of Java Operators · 6bbe2a05
    Aljoscha Krettek 提交于
    Before, FlatMapOperator, GroupReduceOperator, MapOperator, and MapPartitionOperator
    performed the Type extraction themselves while the other Operators had TypeInformation
    parameters. Now the are all unified, which makes it possible to use them from the
    Scala API.
    
    Also Key extraction for selector functions is moved outside of Keys.java
    6bbe2a05
CoGroupOperator.java 23.4 KB