Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-3234

getting the reporter in the recordwriter

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.9.1
    • 0.10.0
    • any

    • The hive code change should take care of existing code base, so it is backward compatible.
    • extend RecordWriter RecordReader to pass in counter

    Description

      We would like to generate some custom statistics and report back to map/reduce later wen implement the
      FileSinkOperator.RecordWriter interface. However, the current interface design doesn't allow us to get the map reduce reporter object. Please extend the current FileSinkOperator.RecordWriter interface so that it's close() method passes in a map reduce reporter object.

      For the same reason, please also extend the RecordReader interface too to include a reporter object so that users can passes in custom map reduce counters.

      Attachments

        1. HIVE-3234.D6699.1.patch
          14 kB
          Phabricator
        2. HIVE-3234.D6699.2.patch
          24 kB
          Phabricator
        3. HIVE-3234.D6987.1.patch
          24 kB
          Phabricator

        Activity

          People

            omalley Owen O'Malley
            jimmy888 Jimmy Hu
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - 48h
                48h
                Remaining:
                Remaining Estimate - 48h
                48h
                Logged:
                Time Spent - Not Specified
                Not Specified