Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-1079

Inconsistent parameter naming in MapPartitionFunction

    XMLWordPrintableJSON

Details

    Description

      The input parameter of the MapPartitionFunction is called records which is different from the naming in the previous functions (GroupReduceFunction, FlatCombineFunction) which name the Iterable values.

      I propose to rename the parameter in MapPartitionFunction to values for consistency reasons.

      Attachments

        Activity

          People

            sewen Stephan Ewen
            fhueske Fabian Hueske
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: